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 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

      public String toString()
      Overrides:
      toString in class Object
    • destroy

      public void destroy()
      Specified by:
      destroy in interface org.springframework.beans.factory.DisposableBean