public class AMQPAcquisitionTopic extends Object
AMQPAcquisitionTopic
class allows administrators to create AMQP
acquisition topics (AMQP bridge in).
The AMQP bridge destinations rely on a particular Joram service which purpose is to maintain valid connections with the foreign AMQP servers.
Modifier and Type | Field and Description |
---|---|
static String |
AMQPAcquisition
Class name of handler allowing to acquire messages to a foreign AMQP provider.
|
Constructor and Description |
---|
AMQPAcquisitionTopic() |
Modifier and Type | Method and Description |
---|---|
static Topic |
create(int serverId,
String dest)
Administration method creating and deploying a AMQP acquisition topic on a given server.
|
static Topic |
create(int serverId,
String name,
String dest)
Administration method creating and deploying a AMQP acquisition topic on a given server.
|
static Topic |
create(int serverId,
String name,
String dest,
Properties props)
Administration method creating and deploying a AMQP acquisition topic on a given server.
|
static Topic |
create(String dest)
Administration method creating and deploying a AMQP acquisition topic on the local server.
|
public static final String AMQPAcquisition
public static Topic create(String dest) throws ConnectException, AdminException
The request fails if the destination deployment fails server side.
Be careful this method use the static AdminModule connection.
dest
- The name of the foreign destination.ConnectException
- If the administration connection is closed or broken.AdminException
- If the request fails.create(int, String, String, Properties)
public static Topic create(int serverId, String dest) throws ConnectException, AdminException
The request fails if the target server does not belong to the platform, or if the destination deployment fails server side.
Be careful this method use the static AdminModule connection.
serverId
- The identifier of the server where deploying the topic.dest
- The name of the foreign destination.ConnectException
- If the administration connection is closed or broken.AdminException
- If the request fails.create(int, String, String, Properties)
public static Topic create(int serverId, String name, String dest) throws ConnectException, AdminException
The request fails if the target server does not belong to the platform, or if the destination deployment fails server side.
Be careful this method use the static AdminModule connection.
serverId
- The identifier of the server where deploying the topic.name
- The name of the created topic.dest
- The name of the foreign destination.ConnectException
- If the administration connection is closed or broken.AdminException
- If the request fails.create(int, String, String, Properties)
public static Topic create(int serverId, String name, String dest, Properties props) throws ConnectException, AdminException
A set of properties is used to configure the distribution destination:
Be careful this method use the static AdminModule connection.
serverId
- The identifier of the server where deploying the topic.name
- The name of the created topic.dest
- The name of the foreign destination.props
- A Properties object containing all needed parameters.ConnectException
- If the administration connection is closed or broken.AdminException
- If the request fails.Copyright © 2020 ScalAgent D.T.. All rights reserved.