Class Amqp1Helper

java.lang.Object

org.frankframework.messaging.amqp.Amqp1Helper

public class Amqp1Helper
extends Object

Method Summary

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

Methods inherited from class Object

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

Method Details

getStreamingMessage

public static @Nullable 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

public static @Nullable 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

public static @NonNull 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

public static @Nullable 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

public static @Nullable 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

public static @Nullable 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