Only in lingo-1.0-M1-jcej: ActiveMQ
diff -u --recursive lingo-1.0-M1/src/java/org/logicblaze/lingo/jms/JmsClientInterceptor.java lingo-1.0-M1-jcej/src/java/org/logicblaze/lingo/jms/JmsClientInterceptor.java
--- lingo-1.0-M1/src/java/org/logicblaze/lingo/jms/JmsClientInterceptor.java	2005-08-17 07:58:41.000000000 -0400
+++ lingo-1.0-M1-jcej/src/java/org/logicblaze/lingo/jms/JmsClientInterceptor.java	2005-09-26 16:03:41.000000000 -0400
@@ -64,6 +64,7 @@
     private String correlationID;
     private Marshaller marshaller;
     private ConnectionFactory connectionFactory;
+    private String jmsType;
 
     public JmsClientInterceptor() {
         setRemoteInvocationFactory(createRemoteInvocationFactory());
@@ -189,6 +190,14 @@
         this.connectionFactory = connectionFactory;
     }
 
+    public String getJmsType() {
+	return jmsType;
+    }
+
+    public void setJmsType(String jmsType) {
+	this.jmsType = jmsType;
+    }
+
     // Implementation methods
     //-------------------------------------------------------------------------
 
@@ -196,6 +205,9 @@
         if (correlationID != null) {
             requestMessage.setJMSCorrelationID(correlationID);
         }
+	if (jmsType != null && !jmsType.equals("")) {
+	   requestMessage.setJMSType(jmsType);
+	}
     }
 
 
diff -u --recursive lingo-1.0-M1/src/java/org/logicblaze/lingo/jms/JmsServiceExporter.java lingo-1.0-M1-jcej/src/java/org/logicblaze/lingo/jms/JmsServiceExporter.java
--- lingo-1.0-M1/src/java/org/logicblaze/lingo/jms/JmsServiceExporter.java	2005-08-17 07:58:41.000000000 -0400
+++ lingo-1.0-M1-jcej/src/java/org/logicblaze/lingo/jms/JmsServiceExporter.java	2005-09-26 15:37:17.000000000 -0400
@@ -45,6 +45,7 @@
     private ConnectionFactory connectionFactory;
     private Destination destination;
     private MessageConsumer consumer;
+    private String messageSelector;
 
     public void afterPropertiesSet() throws Exception {
         if (producer == null) {
@@ -63,7 +64,12 @@
         // do we have a destination specified, if so consume
         if (destination != null) {
             Session session = producer.getSession();
-            consumer = session.createConsumer(destination);
+	    if(messageSelector == null || messageSelector.equals("")) {
+            	consumer = session.createConsumer(destination);
+	    }
+	    else {
+            	consumer = session.createConsumer(destination, messageSelector);
+	    }
             consumer.setMessageListener(this);
         }
 
@@ -107,6 +113,14 @@
         this.destination = destination;
     }
 
+    public String getMessageSelector() {
+	return messageSelector;
+    }
+
+    public void setMessageSelector(String messageSelector) {
+	this.messageSelector = messageSelector;
+    }
+
     /**
      * Send the given RemoteInvocationResult as a JMS message to the originator
      *
Only in lingo-1.0-M1-jcej: target