Ignore:
Timestamp:
06/21/13 12:42:25 (11 years ago)
Author:
stoda
Message:

Adding @MultiMethod?
Broker is not a singleton.

Location:
trunk/src/main/java/omq/common
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • trunk/src/main/java/omq/common/broker/Broker.java

    r53 r54  
    176176                if (responseListener == null) {
    177177                        responseListener = new ResponseListener(this);
     178                        responseListener.start();
    178179                }
    179180                if (eventDispatcher == null) {
    180181                        eventDispatcher = new EventDispatcher(this);
     182                        eventDispatcher.start();
    181183                }
    182184        }
     
    197199                byte[] bytesResponse = serializer.serialize(wrapper);
    198200                channel.basicPublish(UID, "", null, bytesResponse);
    199 
    200                 // Log.saveLog("Server-Serialize", bytesResponse);
    201201        }
    202202
  • trunk/src/main/java/omq/common/event/EventDispatcher.java

    r53 r54  
    5656                boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUES, "false"));
    5757                channel.queueDeclare(event_queue, durable, false, false, null);
     58                logger.info("EventDispatcher creating queue: " + event_queue + ", durable: " + durable);
    5859
    5960                // Declare a new consumer
     
    7273        @Override
    7374        public void run() {
     75                logger.info("EventDispatcher started");
    7476                Delivery delivery;
    7577                Event event;
     
    8486
    8587                                logger.info("Event received -> Topic: " + event.getTopic() + "CorrId: " + event.getCorrId());
    86                                 // Log.saveLog("Client-Deserialize", delivery.getBody());
    87 
    88                                 // long timeEnd = (new Date()).getTime();
    89                                 // Log.saveTimeSendRequestLog("Client-time-response",
    90                                 // event.getCorrId(), "Event!", timeEnd);
    9188
    9289                                // Dispatch it
  • trunk/src/main/java/omq/common/message/Request.java

    r44 r54  
    1515        private boolean async = false;
    1616
     17        private transient boolean multi;
    1718        private transient long timeout;
    1819        private transient int retries;
     
    3435        }
    3536
     37        public Request(String id2, String method2, boolean b, Object[] params2, boolean multi2) {
     38                // TODO Auto-generated constructor stub
     39        }
     40
    3641        public static Request newSyncRequest(String id, String method, Object[] params) {
    3742                return new Request(id, method, false, params);
     
    4550        }
    4651
    47         public static Request newAsyncRequest(String id, String method, Object[] params) {
    48                 return new Request(id, method, true, params);
     52        public static Request newAsyncRequest(String id, String method, Object[] params, boolean multi) {
     53                return new Request(id, method, true, params, multi);
    4954        }
    5055
     
    97102        }
    98103
     104        public boolean isMulti() {
     105                return multi;
     106        }
     107
     108        public void setMulti(boolean multi) {
     109                this.multi = multi;
     110        }
    99111}
Note: See TracChangeset for help on using the changeset viewer.