You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2009/07/31 15:34:55 UTC
svn commit: r799605 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/ActiveMQMessageSender.java
Author: cwiklik
Date: Fri Jul 31 13:34:55 2009
New Revision: 799605
URL: http://svn.apache.org/viewvc?rev=799605&view=rev
Log:
UIMA-1472 Fix ConcurrentHashMap import.
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/ActiveMQMessageSender.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/ActiveMQMessageSender.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/ActiveMQMessageSender.java?rev=799605&r1=799604&r2=799605&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/ActiveMQMessageSender.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/client/ActiveMQMessageSender.java Fri Jul 31 13:34:55 2009
@@ -18,7 +18,7 @@
*/
package org.apache.uima.adapter.jms.client;
-import java.util.List;
+import java.util.concurrent.ConcurrentHashMap;
import javax.jms.BytesMessage;
import javax.jms.Connection;
@@ -26,14 +26,11 @@
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
-import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.command.ActiveMQDestination;
-import edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap;
-
/**
* Initializes JMS session and creates JMS MessageProducer to be used for
* sending messages to a given destination. It extends BaseMessageSender which
@@ -49,7 +46,8 @@
private Session session = null;
private MessageProducer producer = null;
private String destinationName = null;
- private ConcurrentHashMap producerMap = new ConcurrentHashMap();
+ private ConcurrentHashMap<Destination, MessageProducer> producerMap =
+ new ConcurrentHashMap<Destination,MessageProducer>();
public ActiveMQMessageSender(Connection aConnection,
String aDestinationName,