Modifier and Type | Method and Description |
---|---|
AMQPTransportConnectionFactory |
AMQPTransportListener.getConnectionFactory(String name)
Returns the connection factory with this name.
|
static Double |
AMQPTransportUtils.getOptionalDoubleParameter(String key,
Map<String,String> srcMap1,
Map<String,String> srcMap2) |
static Integer |
AMQPTransportUtils.getOptionalIntParameter(String key,
Map<String,String> srcMap1,
Map<String,String> srcMap2) |
List<AMQPTransportMessage> |
AMQPTransportBuffers.getResponseMessageList(int blockSize)
Returns the response messages as a list
|
static void |
AMQPTransportUtils.moveElements(BlockingQueue<AMQPTransportMessage> src,
List<AMQPTransportMessage> dest,
int blockSize)
Move elements between buffers.
|
static Map<String,String> |
AMQPTransportUtils.parseAMQPUri(String amqpUri) |
Modifier and Type | Method and Description |
---|---|
void |
AMQPTransportConnectionFactoryManager.addConnectionFactory(org.apache.axis2.description.Parameter parameter,
ExecutorService es)
Add a connection factory definition into store.
|
AMQPTransportConnectionFactory |
AMQPTransportConnectionFactoryManager.getConnectionFactory(String name)
Get the connection factory with this name.
|
void |
AMQPTransportConnectionFactoryManager.removeConnectionFactory(String name)
Remove and return the connection factory with this name.
|
void |
AMQPTransportConnectionFactoryManager.shutDownConnectionFactories()
Shutdown the open connections to the broker via the connection factory
|
Constructor and Description |
---|
AMQPTransportConnectionFactory(Map<String,String> parameters,
ExecutorService es) |
AMQPTransportConnectionFactory(org.apache.axis2.description.Parameter parameter,
ExecutorService es) |
Modifier and Type | Method and Description |
---|---|
void |
AMQPTransportPollingTask.start()
Start the polling task for this service
|
Modifier and Type | Method and Description |
---|---|
void |
AMQPSender.sendAMQPMessage(org.apache.axis2.context.MessageContext mc,
String correlationId,
String replyTo) |
Copyright © 2005-2017 Apache Software Foundation. All Rights Reserved.