Commit 349e1fd7 authored by afreyssin's avatar afreyssin
Browse files

Changes about interceptors handling.

parent 7281bb1a
......@@ -409,7 +409,7 @@ public class Connection implements javax.jms.Connection {
* <br>The execution follows the order of the elements within the list.
* @return the list of the IN message interceptors.
*/
public final List getInInterceptors(){
final List getInInterceptors() {
return factoryParameters.inInterceptors;
}
/**
......@@ -419,7 +419,7 @@ public class Connection implements javax.jms.Connection {
* <br>The execution follows the order of the elements within the list.
* @return the list of the OUT message interceptors.
*/
public final List getOutInterceptors(){
final List getOutInterceptors() {
return factoryParameters.outInterceptors;
}
/**
......
......@@ -27,9 +27,8 @@ import javax.jms.Session;
/**
* Session level message interceptor interface.
* The <code>MessageInterceptor</code> should be
* implemented by any class whose instances are
* intended to intercept either or both following
* The <code>MessageInterceptor</code> should be implemented by any class
* whose instances are intended to intercept either or both following
* operations within a {@link javax.jms.Session.Session JMS Session}:
* <ul>
* <li>{@link javax.jms.MessageProducer#send(Message) sending a message}</li>
......@@ -38,8 +37,8 @@ import javax.jms.Session;
* The <code>interceptor</code> can be attached to a
* {@link javax.jms.Session.Session JMS Session} through configuration
* (see <code>joramAdmin.xml</code>) as <code>IN</code>
* (when consumming a message) or <code>OUT</code> (when producing a message)
* intereceptor.
* (when consuming a message) or <code>OUT</code> (when producing a message)
* interceptor.
* @author benammoura
*/
public interface MessageInterceptor {
......
......@@ -578,21 +578,21 @@ public class Session implements javax.jms.Session {
private List inInterceptors;
private List outInterceptors;
/**
* Sets the list of IN message interceptors.
* @param pInInterceptors
*/
public void setInMessageInterceptors(List pInInterceptors) {
inInterceptors = pInInterceptors;
}
/**
* Sets the OUT message interceptor.
* @param pOutInterceptor
*/
public void setOutMessageInterceptors(List pOutInterceptors) {
outInterceptors = pOutInterceptors;
}
// /**
// * Sets the list of IN message interceptors.
// * @param pInInterceptors
// */
// public void setInMessageInterceptors(List pInInterceptors) {
// inInterceptors = pInInterceptors;
// }
//
// /**
// * Sets the OUT message interceptor.
// * @param pOutInterceptor
// */
// public void setOutMessageInterceptors(List pOutInterceptors) {
// outInterceptors = pOutInterceptors;
// }
/**
* Opens a session.
......@@ -2045,8 +2045,7 @@ public class Session implements javax.jms.Session {
checkThreadOfControl();
// Updating the message property fields:
String msgID = cnx.nextMessageId();
msg.setJMSMessageID(msgID);
msg.setJMSMessageID(cnx.nextMessageId());
msg.setJMSDeliveryMode(deliveryMode);
msg.setJMSDestination(dest);
if (timeToLive == 0) {
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment