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 TypeMethodDescriptionvoiddestroy()org.apache.qpid.protonj2.client.Connectionorg.apache.qpid.protonj2.client.SessiongetSession(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:
destroyin interfaceorg.springframework.beans.factory.DisposableBean
-