Class AmqpConnectionFactory
java.lang.Object
org.frankframework.messaging.amqp.AmqpConnectionFactory
- All Implemented Interfaces:
org.springframework.beans.factory.DisposableBean
public class AmqpConnectionFactory
extends Object
implements org.springframework.beans.factory.DisposableBean
-
Constructor Summary
ConstructorsConstructorDescriptionAmqpConnectionFactory
(String resourceName, FrankResource resource, org.apache.qpid.protonj2.client.Client client) -
Method Summary
Modifier and TypeMethodDescriptionvoid
destroy()
org.apache.qpid.protonj2.client.Connection
org.apache.qpid.protonj2.client.Session
getSession
(org.apache.qpid.protonj2.client.SessionOptions sessionOptions) toString()
-
Constructor Details
-
AmqpConnectionFactory
public AmqpConnectionFactory(String resourceName, FrankResource resource, org.apache.qpid.protonj2.client.Client client)
-
-
Method Details
-
getConnection
public org.apache.qpid.protonj2.client.Connection getConnection() throws org.apache.qpid.protonj2.client.exceptions.ClientException- Throws:
org.apache.qpid.protonj2.client.exceptions.ClientException
-
getSession
public org.apache.qpid.protonj2.client.Session getSession(org.apache.qpid.protonj2.client.SessionOptions sessionOptions) throws org.apache.qpid.protonj2.client.exceptions.ClientException - Throws:
org.apache.qpid.protonj2.client.exceptions.ClientException
-
toString
-
destroy
public void destroy()- Specified by:
destroy
in interfaceorg.springframework.beans.factory.DisposableBean
-