Package org.frankframework.messaging.amqp

Class AmqpListenerContainer

java.lang.Object

org.frankframework.messaging.amqp.AmqpListenerContainer

public class AmqpListenerContainer
extends Object

Run all AMQP listeners that use the same connection in a single Session, for more efficient use of system resources.

Constructor Summary

Constructors

Constructor	Description
AmqpListenerContainer()

Method Summary

Modifier and Type	Method	Description
void	closeAllListeners(org.apache.qpid.protonj2.client.exceptions.ClientException ex)
boolean	closeListener(AmqpListener amqpListener)	Return true when last listener is closed
boolean	isOpen()
void	openConnection(String connectionName)	Open connection for which this instance is managing receivers.
void	openListener(AmqpListener amqpListener)	Open a listener in this listener-container.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AmqpListenerContainer

public AmqpListenerContainer()

Method Details

openConnection

public void openConnection(@Nonnull
 String connectionName)
                    throws LifecycleException

Open connection for which this instance is managing receivers. This connection needs to be opened before any AmqpListeners can be registered with this container.

Parameters:

connectionName -

Throws:

LifecycleException

isOpen

public boolean isOpen()

openListener

public void openListener(@Nonnull
 AmqpListener amqpListener)

Open a listener in this listener-container. The listener-container should have an open connection before a listener can be opened, and the listener connection-name should be for the same connection as this listener-container instance.

Parameters:

amqpListener -

closeListener

public boolean closeListener(AmqpListener amqpListener)

Return true when last listener is closed

Parameters:

amqpListener -

Returns:

closeAllListeners

public void closeAllListeners(org.apache.qpid.protonj2.client.exceptions.ClientException ex)