public abstract class BasicMessageProducer extends Closeable implements MessageProducer
Modifier | Constructor and Description |
---|---|
protected |
BasicMessageProducer(org.slf4j.Logger logger,
AMQConnection connection,
AMQDestination destination,
boolean transacted,
int channelId,
AMQSession session,
long producerId,
Boolean immediate,
Boolean mandatory) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes this object.
|
protected AMQDestination |
getAMQDestination() |
protected int |
getChannelId() |
protected AMQConnection |
getConnection() |
long |
getDeliveryDelay() |
int |
getDeliveryMode() |
javax.jms.Destination |
getDestination()
The Destination used for this consumer, if specified upon creation.
|
boolean |
getDisableMessageID() |
boolean |
getDisableMessageTimestamp() |
int |
getPriority() |
protected org.apache.qpid.client.BasicMessageProducer.PublishMode |
getPublishMode() |
AMQSession |
getSession()
The session used to create this producer
|
long |
getTimeToLive() |
protected String |
getUserID() |
boolean |
isBound(AMQDestination destination) |
protected boolean |
isDisableTimestamps()
If true, messages will not get a timestamp.
|
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.Destination destination,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory) |
void |
send(javax.jms.Destination destination,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate) |
void |
send(javax.jms.Message message) |
void |
send(javax.jms.Message message,
int deliveryMode) |
void |
send(javax.jms.Message message,
int deliveryMode,
boolean immediate) |
void |
send(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive) |
protected void |
sendImpl(AMQDestination destination,
javax.jms.Message origMessage,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate,
long deliveryDelay)
The caller of this method must hold the failover mutex.
|
protected void |
setChannelId(int channelId) |
void |
setDeliveryDelay(long deliveryDelay) |
void |
setDeliveryMode(int i) |
protected void |
setDestination(AMQDestination destination) |
void |
setDisableMessageID(boolean b) |
void |
setDisableMessageTimestamp(boolean b) |
protected void |
setDisableTimestamps(boolean disableTimestamps) |
void |
setPriority(int i) |
protected void |
setPublishMode(org.apache.qpid.client.BasicMessageProducer.PublishMode publishMode) |
protected void |
setSession(AMQSession session) |
void |
setTimeToLive(long l) |
protected void |
setUserID(String userID) |
checkNotClosed, isClosed, isClosing, setClosed, setClosing
protected BasicMessageProducer(org.slf4j.Logger logger, AMQConnection connection, AMQDestination destination, boolean transacted, int channelId, AMQSession session, long producerId, Boolean immediate, Boolean mandatory) throws QpidException
QpidException
protected AMQConnection getConnection()
public void setDisableMessageID(boolean b) throws javax.jms.JMSException
setDisableMessageID
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 void setDisableMessageTimestamp(boolean b) throws javax.jms.JMSException
setDisableMessageTimestamp
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 void setDeliveryMode(int i) throws javax.jms.JMSException
setDeliveryMode
in interface javax.jms.MessageProducer
javax.jms.JMSException
public int getDeliveryMode() throws javax.jms.JMSException
getDeliveryMode
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setPriority(int i) throws javax.jms.JMSException
setPriority
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 void setTimeToLive(long l) throws javax.jms.JMSException
setTimeToLive
in interface javax.jms.MessageProducer
javax.jms.JMSException
public long getTimeToLive() throws javax.jms.JMSException
getTimeToLive
in interface javax.jms.MessageProducer
javax.jms.JMSException
protected AMQDestination getAMQDestination()
public javax.jms.Destination getDestination() throws javax.jms.JMSException
getDestination
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void close() throws javax.jms.JMSException
Closeable
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) throws javax.jms.JMSException
javax.jms.JMSException
public void send(javax.jms.Message message, int deliveryMode, boolean immediate) throws javax.jms.JMSException
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 send(javax.jms.Destination destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive, boolean mandatory) throws javax.jms.JMSException
javax.jms.JMSException
public void send(javax.jms.Destination destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive, boolean mandatory, boolean immediate) throws javax.jms.JMSException
javax.jms.JMSException
protected void sendImpl(AMQDestination destination, javax.jms.Message origMessage, int deliveryMode, int priority, long timeToLive, boolean mandatory, boolean immediate, long deliveryDelay) throws javax.jms.JMSException
destination
- origMessage
- deliveryMode
- priority
- timeToLive
- mandatory
- immediate
- deliveryDelay
- javax.jms.JMSException
public AMQSession getSession()
public boolean isBound(AMQDestination destination) throws javax.jms.JMSException
javax.jms.JMSException
protected boolean isDisableTimestamps()
protected void setDisableTimestamps(boolean disableTimestamps)
protected void setDestination(AMQDestination destination)
protected int getChannelId()
protected void setChannelId(int channelId)
protected void setSession(AMQSession session)
protected String getUserID()
protected void setUserID(String userID)
protected org.apache.qpid.client.BasicMessageProducer.PublishMode getPublishMode()
protected void setPublishMode(org.apache.qpid.client.BasicMessageProducer.PublishMode publishMode)
public long getDeliveryDelay()
public void setDeliveryDelay(long deliveryDelay)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.