Changeset 20 for trunk


Ignore:
Timestamp:
05/23/13 15:46:29 (11 years ago)
Author:
stoda
Message:
 
Location:
trunk/objectmq/src/omq
Files:
4 edited

Legend:

Unmodified
Added
Removed
  • trunk/objectmq/src/omq/client/proxy/Proxymq.java

    r19 r20  
    121121                // Publish the request
    122122                if (request.isAsync()) {
    123                         System.out.println("Publish async request ->" + request.getId());
     123                        System.out.println("Publish async request -> " + request.getId());
    124124                        publishAsyncRequest(request);
    125125                        return null;
    126126                } else {
    127                         System.out.println("Publish sync request ->" + request.getId());
     127                        System.out.println("Publish sync request -> " + request.getId());
    128128                        return publishSyncRequest(request, method.getReturnType());
    129129                }
  • trunk/objectmq/src/omq/client/remote/response/ResponseListener.java

    r19 r20  
    6060                                // Get the response with its uid
    6161                                uid_request = delivery.getProperties().getCorrelationId();
    62                                 System.out.println("Response reveived -> " + uid_request);
     62                                System.out.println("Response received -> " + uid_request);
    6363
    6464                                // Stores the new response
  • trunk/objectmq/src/omq/common/event/EventDispatcher.java

    r19 r20  
    133133                        String queueName = env.getProperty(ParameterQueue.EVENT_REPLY_QUEUE);
    134134                        String reference = e.getTopic();
     135
     136                        System.out.println("EventDispatcher declaring fanout -> " + reference + " Binding with: " + queueName);
     137
    135138                        channel.exchangeDeclare(reference, "fanout");
    136139                        channel.queueBind(queueName, reference, "");
  • trunk/objectmq/src/omq/server/remote/request/RemoteObject.java

    r16 r20  
    8181
    8282                // Declares and bindings
     83                System.out.println("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue);
    8384                channel.exchangeDeclare(exchange, "direct");
    8485                channel.queueDeclare(queue, false, false, false, null);
     
    8687
    8788                // Declare the event topic fanout
     89                System.out.println("RemoteObject: " + UID + " declaring fanout exchange: " + UID);
    8890                channel.exchangeDeclare(UID, "fanout");
    8991
     
    101103                        try {
    102104                                Delivery delivery = consumer.nextDelivery();
     105                                System.out.println("RemoteObject: " + UID + " has received a message");
    103106                                remoteWrapper.notifyDelivery(delivery);
    104107                        } catch (InterruptedException i) {
Note: See TracChangeset for help on using the changeset viewer.