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 2018/02/26 18:59:16 UTC
svn commit: r1825404 -
/uima/uima-as/branches/uima-as-3/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/message/PendingMessageImpl.java
Author: cwiklik
Date: Mon Feb 26 18:59:16 2018
New Revision: 1825404
URL: http://svn.apache.org/viewvc?rev=1825404&view=rev
Log:
UIMA-5280
Added:
uima/uima-as/branches/uima-as-3/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/message/PendingMessageImpl.java
- copied, changed from r1822820, uima/uima-as/branches/uima-as-3/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/message/PendingMessage.java
Copied: uima/uima-as/branches/uima-as-3/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/message/PendingMessageImpl.java (from r1822820, uima/uima-as/branches/uima-as-3/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/message/PendingMessage.java)
URL: http://svn.apache.org/viewvc/uima/uima-as/branches/uima-as-3/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/message/PendingMessageImpl.java?p2=uima/uima-as/branches/uima-as-3/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/message/PendingMessageImpl.java&p1=uima/uima-as/branches/uima-as-3/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/message/PendingMessage.java&r1=1822820&r2=1825404&rev=1825404&view=diff
==============================================================================
--- uima/uima-as/branches/uima-as-3/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/message/PendingMessage.java (original)
+++ uima/uima-as/branches/uima-as-3/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/message/PendingMessageImpl.java Mon Feb 26 18:59:16 2018
@@ -19,17 +19,37 @@
package org.apache.uima.adapter.jms.message;
import java.util.HashMap;
+import java.util.Map;
-public class PendingMessage extends HashMap<Object, Object> {
-
-private static final long serialVersionUID = 3512718154731557413L;
-private int messageType;
-
- public PendingMessage(int aMessageType) {
- messageType = aMessageType;
- }
-
- public int getMessageType() {
- return messageType;
- }
+public class PendingMessageImpl implements PendingMessage {
+
+ private static final long serialVersionUID = 3512718154731557413L;
+ private final int messageType;
+ private Map<String, Object> cache = new HashMap<>();
+
+ public PendingMessageImpl(int aMessageType) {
+ messageType = aMessageType;
+ }
+
+ public int getMessageType() {
+ return messageType;
+ }
+
+ public Object getProperty(String propertyKey) {
+
+ return cache.get(propertyKey);
+ }
+
+ public void addProperty(String propertyKey, Object property) {
+ cache.put(propertyKey, property);
+ }
+ public String getPropertyAsString(String key) {
+ return (String)getProperty(key);
+ }
+ public int getPropertyAsInt(String key) {
+ return (Integer)getProperty(key);
+ }
+ public byte[] getPropertyAsBytesArray(String key) {
+ return (byte[])getProperty(key);
+ }
}