Changeset 70 for trunk/src/main/java/omq/client/proxy

Timestamp:

06/28/13 12:41:11 (11 years ago)

Author:

stoda

Message:

MultiProxymq? added

Location:

trunk/src/main/java/omq/client/proxy

Files:

• MultiProxymq.java (added)
• Proxymq.java (modified) (8 diffs)

trunk/src/main/java/omq/client/proxy/Proxymq.java

@@ -5 +5 @@
 import java.lang.reflect.InvocationHandler;
 import java.lang.reflect.Method;
-import java.lang.reflect.Proxy;
 import java.util.Collection;
 import java.util.HashMap;
@@ -50 +49 @@
 
         private String uid;
+        private transient String exchange;
+        private transient String multiExchange;
+        private transient String replyQueueName;
         private transient String serializerType;
         private transient Broker broker;
@@ -96 +98 @@
                 // this.channel = Broker.getChannel();
                 env = broker.getEnvironment();
+                exchange = env.getProperty(ParameterQueue.RPC_EXCHANGE);
+                multiExchange = multi + exchange;
+                replyQueueName = env.getProperty(ParameterQueue.RPC_REPLY_QUEUE);
 
                 // set the serializer type
@@ -134 +139 @@
                 if (request.isAsync()) {
                         logger.debug("Publish async request -> " + request.getId());
-                        publishAsyncRequest(request);
+                        publishMessage(request, replyQueueName);
                 } else {
                         logger.debug("Publish sync request -> " + request.getId());
@@ -151 +156 @@
 
                 if (request.isMulti()) {
-                        exchange = multi + env.getProperty(ParameterQueue.RPC_EXCHANGE);
+                        exchange = multiExchange;
                         routingkey = "";
                 } else {
-                        exchange = env.getProperty(ParameterQueue.RPC_EXCHANGE);
+                        exchange = this.exchange;
                         routingkey = uid;
                 }
@@ -166 +171 @@
         }
 
-        private void publishAsyncRequest(Request request) throws Exception {
-                // Get the environment properties
-                String replyQueueName = env.getProperty(ParameterQueue.RPC_REPLY_QUEUE);
-                publishMessage(request, replyQueueName);
-        }
-
         private Object publishSyncRequest(Request request, Class<?> type) throws Exception {
                 String corrId = request.getId();
@@ -177 +176 @@
                 int retries = request.getRetries();
                 long timeout = request.getTimeout();
-
-                // Get the environment properties
-                String replyQueueName = env.getProperty(ParameterQueue.RPC_REPLY_QUEUE);
 
                 // Publish the message
@@ -296 +292 @@
 
         /**
-         * Returns an instance of a proxy class for the specified interfaces that
-         * dispatches method invocations to the specified invocation handler. * @param
-         * loader
-         * 
-         * @param loader
-         *            the class loader to define the proxy class
-         * 
-         * @param interfaces
-         *            the list of interfaces for the proxy class to implement
-         * @param proxy
-         *            the invocation handler to dispatch method invocations to
-         * @return a proxy instance with the specified invocation handler of a proxy
-         *         class that is defined by the specified class loader and that
-         *         implements the specified interfaces
-         */
-        public static Object newProxyInstance(ClassLoader loader, Class<?>[] interfaces, Proxymq proxy) {
-                return Proxy.newProxyInstance(loader, interfaces, proxy);
-        }
-
-        /**
          * Gets the Map used internally to retreive the response of the server
          *