Package org.frankframework.messaging.amqp

Class Amqp1Helper

java.lang.Object

org.frankframework.messaging.amqp.Amqp1Helper

public class Amqp1Helper
extends Object

Method Summary

Modifier and Type	Method	Description
static Message	convertAmqpMessageToFFMessage(org.apache.qpid.protonj2.client.Message<?> amqpMessage)
static Message	getMessage(org.apache.qpid.protonj2.client.Connection connection, String address, AddressType addressType)
static Message	getMessage(AmqpConnectionFactoryFactory connectionFactory, String connectionName, String address, AddressType addressType)
static Message	getStreamingMessage(org.apache.qpid.protonj2.client.Connection connection, String address, AddressType addressType)
static Message	getStreamingMessage(AmqpConnectionFactoryFactory connectionFactory, String connectionName, String address, AddressType addressType)
static String	sendFFMessage(AmqpConnectionFactoryFactory connectionFactory, String connectionName, String address, AddressType addressType, Message message)

Methods inherited from class java.lang.Object

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

Method Details

getStreamingMessage

@Nullable
public static Message getStreamingMessage(@Nonnull
 AmqpConnectionFactoryFactory connectionFactory,
 @Nonnull
 String connectionName,
 @Nonnull
 String address,
 @Nonnull
 AddressType addressType)
                                   throws org.apache.qpid.protonj2.client.exceptions.ClientException,
IOException

Throws:

org.apache.qpid.protonj2.client.exceptions.ClientException

IOException

getStreamingMessage

@Nullable
public static Message getStreamingMessage(@Nonnull
 org.apache.qpid.protonj2.client.Connection connection,
 @Nonnull
 String address,
 @Nonnull
 AddressType addressType)
                                   throws org.apache.qpid.protonj2.client.exceptions.ClientException,
IOException

Throws:

org.apache.qpid.protonj2.client.exceptions.ClientException

IOException

convertAmqpMessageToFFMessage

@Nonnull
public static Message convertAmqpMessageToFFMessage(@Nonnull
 org.apache.qpid.protonj2.client.Message<?> amqpMessage)
                                             throws IOException,
org.apache.qpid.protonj2.client.exceptions.ClientException

Throws:

IOException

org.apache.qpid.protonj2.client.exceptions.ClientException

getMessage

@Nullable
public static Message getMessage(@Nonnull
 AmqpConnectionFactoryFactory connectionFactory,
 @Nonnull
 String connectionName,
 @Nonnull
 String address,
 @Nonnull
 AddressType addressType)
                          throws org.apache.qpid.protonj2.client.exceptions.ClientException,
IOException

Throws:

org.apache.qpid.protonj2.client.exceptions.ClientException

IOException

getMessage

@Nullable
public static Message getMessage(@Nonnull
 org.apache.qpid.protonj2.client.Connection connection,
 @Nonnull
 String address,
 @Nonnull
 AddressType addressType)
                          throws org.apache.qpid.protonj2.client.exceptions.ClientException,
IOException

Throws:

org.apache.qpid.protonj2.client.exceptions.ClientException

IOException

sendFFMessage

@Nullable
public static String sendFFMessage(@Nonnull
 AmqpConnectionFactoryFactory connectionFactory,
 @Nonnull
 String connectionName,
 @Nonnull
 String address,
 @Nonnull
 AddressType addressType,
 @Nonnull
 Message message)
                            throws org.apache.qpid.protonj2.client.exceptions.ClientException,
IOException

Throws:

org.apache.qpid.protonj2.client.exceptions.ClientException

IOException