public class JmsMessageProducer extends Object implements AutoCloseable, javax.jms.MessageProducer
Modifier and Type | Field and Description |
---|---|
protected AtomicBoolean |
closed |
protected JmsConnection |
connection |
protected int |
deliveryMode |
protected boolean |
disableMessageId |
protected boolean |
disableTimestamp |
protected Exception |
failureCause |
protected boolean |
flexibleDestination |
protected AtomicLong |
messageSequence |
protected int |
priority |
protected JmsProducerInfo |
producerInfo |
protected JmsSession |
session |
protected long |
timeToLive |
Modifier | Constructor and Description |
---|---|
protected |
JmsMessageProducer(JmsProducerId producerId,
JmsSession session,
JmsDestination destination) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkClosed() |
void |
close() |
protected void |
doClose()
Called to initiate shutdown of Producer resources and request that the remote
peer remove the registered producer.
|
int |
getDeliveryMode() |
javax.jms.Destination |
getDestination() |
boolean |
getDisableMessageID() |
boolean |
getDisableMessageTimestamp() |
protected long |
getNextMessageSequence() |
int |
getPriority() |
protected JmsProducerId |
getProducerId() |
long |
getTimeToLive() |
protected void |
onConnectionInterrupted() |
protected void |
onConnectionRecovered(Provider provider) |
protected void |
onConnectionRecovery(Provider provider) |
protected void |
onConnectionRestored() |
void |
send(javax.jms.Destination destination,
javax.jms.Message message) |
void |
send(javax.jms.Destination destination,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
send(javax.jms.Message message) |
void |
send(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
setDeliveryMode(int deliveryMode) |
void |
setDisableMessageID(boolean value) |
void |
setDisableMessageTimestamp(boolean value) |
void |
setPriority(int defaultPriority) |
void |
setTimeToLive(long timeToLive) |
protected void |
shutdown()
Called to release all producer resources without requiring a destroy request
to be sent to the remote peer.
|
protected void |
shutdown(Exception cause) |
protected final JmsSession session
protected final JmsConnection connection
protected JmsProducerInfo producerInfo
protected final boolean flexibleDestination
protected int deliveryMode
protected int priority
protected long timeToLive
protected final AtomicBoolean closed
protected boolean disableMessageId
protected boolean disableTimestamp
protected final AtomicLong messageSequence
protected Exception failureCause
protected JmsMessageProducer(JmsProducerId producerId, JmsSession session, JmsDestination destination) throws javax.jms.JMSException
javax.jms.JMSException
public void close() throws javax.jms.JMSException
close
in interface AutoCloseable
close
in interface javax.jms.MessageProducer
javax.jms.JMSException
protected void doClose() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs during the close operation.protected void shutdown() throws javax.jms.JMSException
javax.jms.JMSException
- if an internal error occurs during the shutdown operation.protected void shutdown(Exception cause) throws javax.jms.JMSException
javax.jms.JMSException
public int getDeliveryMode() throws javax.jms.JMSException
getDeliveryMode
in interface javax.jms.MessageProducer
javax.jms.JMSException
public javax.jms.Destination getDestination() throws javax.jms.JMSException
getDestination
in interface javax.jms.MessageProducer
javax.jms.JMSException
public boolean getDisableMessageID() throws javax.jms.JMSException
getDisableMessageID
in interface javax.jms.MessageProducer
javax.jms.JMSException
public boolean getDisableMessageTimestamp() throws javax.jms.JMSException
getDisableMessageTimestamp
in interface javax.jms.MessageProducer
javax.jms.JMSException
public int getPriority() throws javax.jms.JMSException
getPriority
in interface javax.jms.MessageProducer
javax.jms.JMSException
public long getTimeToLive() throws javax.jms.JMSException
getTimeToLive
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Message message) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Destination destination, javax.jms.Message message) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Destination destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setDeliveryMode(int deliveryMode) throws javax.jms.JMSException
setDeliveryMode
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setDisableMessageID(boolean value) throws javax.jms.JMSException
setDisableMessageID
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setDisableMessageTimestamp(boolean value) throws javax.jms.JMSException
setDisableMessageTimestamp
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setPriority(int defaultPriority) throws javax.jms.JMSException
setPriority
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setTimeToLive(long timeToLive) throws javax.jms.JMSException
setTimeToLive
in interface javax.jms.MessageProducer
javax.jms.JMSException
protected JmsProducerId getProducerId()
protected long getNextMessageSequence()
protected void checkClosed() throws javax.jms.IllegalStateException
javax.jms.IllegalStateException
protected void onConnectionInterrupted()
protected void onConnectionRecovery(Provider provider) throws Exception
Exception
protected void onConnectionRecovered(Provider provider) throws Exception
Exception
protected void onConnectionRestored()
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.