| Package | Description |
|---|---|
| org.mule.extensions.jms.api.operation | |
| org.mule.extensions.jms.internal.connection.provider | |
| org.mule.extensions.jms.internal.connection.provider.activemq |
| Modifier and Type | Method and Description |
|---|---|
void |
JmsAck.ack(JmsConnection connection,
String ackId)
Allows the user to perform an ACK when the
AckMode.MANUAL mode is elected while consuming the Message. |
org.mule.runtime.extension.api.runtime.operation.Result<Object,JmsAttributes> |
JmsConsume.consume(JmsConnection connection,
JmsConfig config,
String destination,
ConsumerType consumerType,
AckMode ackMode,
String selector,
String contentType,
String encoding,
Long maximumWaitTime,
TimeUnit waitTimeUnit)
Operation that allows the user to consume a single
Message from a given Destination. |
void |
JmsPublish.publish(JmsConfig config,
JmsConnection connection,
String destination,
DestinationType destinationType,
MessageBuilder messageBuilder,
Boolean persistentDelivery,
Integer priority,
Long timeToLive,
TimeUnit timeToLiveUnit,
Long deliveryDelay,
TimeUnit deliveryDelayUnit)
Operation that allows the user to send a
Message to a JMS {@link Destination |
org.mule.runtime.extension.api.runtime.operation.Result<Object,JmsAttributes> |
JmsPublishConsume.publishConsume(JmsConfig config,
JmsConnection connection,
String destination,
MessageBuilder messageBuilder,
Boolean persistentDelivery,
Integer priority,
Long timeToLive,
TimeUnit timeToLiveUnit,
Long maximumWaitTime,
TimeUnit waitTimeUnit,
AckMode ackMode,
Long deliveryDelay,
TimeUnit deliveryDelayUnit)
Operation that allows the user to send a message to a JMS
Destination and waits for a response
either to the provided ReplyTo destination or to a temporary Destination created dynamically |
| Modifier and Type | Method and Description |
|---|---|
JmsConnection |
BaseConnectionProvider.connect() |
| Modifier and Type | Method and Description |
|---|---|
void |
BaseConnectionProvider.disconnect(JmsConnection jmsConnection) |
protected void |
BaseConnectionProvider.doClose(JmsConnection jmsConnection) |
protected void |
BaseConnectionProvider.doStop(JmsConnection jmsConnection) |
org.mule.runtime.api.connection.ConnectionValidationResult |
BaseConnectionProvider.validate(JmsConnection jmsConnection) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ActiveMQConnectionProvider.doClose(JmsConnection jmsConnection) |
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.