Changeset 30


Ignore:
Timestamp:
06/03/13 17:13:09 (11 years ago)
Author:
gguerrero
Message:

Comment logs.

Location:
trunk/objectmq/src/omq
Files:
5 edited

Legend:

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

    r20 r30  
    66import java.lang.reflect.Proxy;
    77import java.util.Collection;
     8import java.util.Date;
    89import java.util.HashMap;
    910import java.util.Hashtable;
     
    2021import omq.common.message.Request;
    2122import omq.common.message.Response;
    22 import omq.common.util.Log;
    2323import omq.common.util.ParameterQueue;
    2424import omq.common.util.Serializer;
     
    9898        @Override
    9999        public Object invoke(Object proxy, Method method, Object[] arguments) throws Throwable {
     100                //long timeStart = (new Date()).getTime();
     101               
    100102                // Local methods only
    101103                String methodName = method.getName();
     
    119121                Request request = createRequest(method, arguments);
    120122
     123                //Log.saveTimeSendRequestLog("Client-time-request", request.getId(), method.getName(), timeStart);
     124               
     125                Object response = null;
    121126                // Publish the request
    122127                if (request.isAsync()) {
    123128                        System.out.println("Publish async request -> " + request.getId());
    124129                        publishAsyncRequest(request);
    125                         return null;
    126130                } else {
    127                         System.out.println("Publish sync request -> " + request.getId());
    128                         return publishSyncRequest(request, method.getReturnType());
    129                 }
     131                        System.out.println("Publish sync request -> " + request.getId());                       
     132                        response = publishSyncRequest(request, method.getReturnType());
     133                       
     134                        //long timeEnd = (new Date()).getTime();
     135                        //Log.saveTimeSendRequestLog("Client-time-response", request.getId(), method.getName(), timeEnd);
     136                }
     137               
     138                return response;
    130139        }
    131140
     
    143152                byte[] bytesRequest = Serializer.serialize(request);
    144153                channel.basicPublish(exchange, routingkey, props, bytesRequest);
    145                 Log.saveLog("Client-Serialize", bytesRequest);
     154                //Log.saveLog("Client-Serialize", bytesRequest);
    146155        }
    147156
     
    213222                        }
    214223                        resp = Serializer.deserializeResponse(results.get(corrId), type);
    215                         Log.saveLog("Client-Deserialize", results.get(corrId));
     224                        //Log.saveLog("Client-Deserialize", results.get(corrId));
     225                       
    216226                        // Remove and indicate the key exists (a hashmap can contain a null
    217227                        // object, using this we'll know whether a response has been
  • trunk/objectmq/src/omq/common/broker/Broker.java

    r29 r30  
    115115                System.out.println("EventTrigger fanout exchange: " + UID + " Event topic: " + UID + " Event corrID: " + event.getCorrId());
    116116                channel.exchangeDeclare(UID, "fanout");
    117                 channel.basicPublish(UID, "", null, Serializer.serialize(wrapper));
     117               
     118                byte[] bytesResponse = Serializer.serialize(wrapper);
     119                channel.basicPublish(UID, "", null, bytesResponse);
     120
     121                //Log.saveLog("Server-Serialize", bytesResponse);                       
    118122        }
    119123
  • trunk/objectmq/src/omq/common/event/EventDispatcher.java

    r28 r30  
    9696
    9797                                System.out.println("Event received -> Topic: " + event.getTopic() + "CorrId: " + event.getCorrId());
    98 
     98                                //Log.saveLog("Client-Deserialize", delivery.getBody());
     99                               
     100                                //long timeEnd = (new Date()).getTime();
     101                                //Log.saveTimeSendRequestLog("Client-time-response", event.getCorrId(), "Event!",  timeEnd);
     102                               
    99103                                // Dispatch it
    100104                                dispatch(event.getTopic(), event);
  • trunk/objectmq/src/omq/common/util/Log.java

    r18 r30  
    22
    33import java.io.File;
    4 import java.io.FileOutputStream;
    54import java.io.FileWriter;
    65import java.io.IOException;
     
    98
    109import omq.exception.EnvironmentException;
    11 
    12 import org.apache.commons.io.IOUtils;
    1310
    1411public class Log {
     
    2219                                long timeNow = (new Date()).getTime();
    2320
    24                                 File outputFolder = new File(debugPath + File.separator + processName);
     21                                File outputFolder = new File(debugPath + File.separator);
    2522                                outputFolder.mkdirs();
     23                               
     24//                              File outputFolder = new File(debugPath + File.separator + processName);
     25//                              outputFolder.mkdirs();
    2626
    27                                 File outputFileContent = new File(outputFolder.getAbsoluteFile() + File.separator + "content_" + timeNow);
    28                                 FileOutputStream outputStream = new FileOutputStream(outputFileContent);
    29                                 IOUtils.write(bytesResponse, outputStream);
    30                                 outputStream.close();
    31                                
     27//                              File outputFileContent = new File(outputFolder.getAbsoluteFile() + File.separator + "content_" + timeNow);
     28//                              FileOutputStream outputStream = new FileOutputStream(outputFileContent);
     29//                              IOUtils.write(bytesResponse, outputStream);
     30//                              outputStream.close();
     31
    3232                                File outputFileLog = new File(debugPath + File.separator + "log");
    3333                                boolean exist = outputFileLog.exists();
     
    4444                }
    4545        }
     46       
     47        public static void saveTimeSendRequestLog(String processName, String coorId, String method, long timeNow) throws IOException {
     48                try {
     49                        Properties env = Environment.getEnvironment();
     50
     51                        String debugPath = env.getProperty(ParameterQueue.DEBUGFILE, "");
     52                        if (debugPath.length() > 0) {                   
     53                                File outputFolder = new File(debugPath + File.separator + processName);
     54                                outputFolder.mkdirs();
     55                               
     56                                File outputFileLog = new File(outputFolder + File.separator + "log");
     57                                boolean exist = outputFileLog.exists();
     58                               
     59                                FileWriter fw = new FileWriter(outputFileLog, true); // the true will append the new data
     60                                if(!exist){
     61                                        fw.write("#CoorId\tMethod\tDate\n");
     62                                }
     63                                fw.write(coorId + "\t" + method + "\t" + timeNow + "\n");
     64                                fw.close();
     65                        }
     66                } catch (EnvironmentException e) {
     67                        throw new IOException(e.getMessage(), e);
     68                }
     69        }       
    4670}
  • trunk/objectmq/src/omq/server/remote/request/InvocationThread.java

    r23 r30  
    55import omq.common.message.Request;
    66import omq.common.message.Response;
    7 import omq.common.util.Log;
    87import omq.common.util.Serializer;
    98
     
    3635                                // Deserialize the json
    3736                                Request request = Serializer.deserializeRequest(delivery.getBody(), obj);
    38                                 Log.saveLog("Server-Deserialize", delivery.getBody());
     37                                //Log.saveLog("Server-Deserialize", delivery.getBody());
    3938
    4039                                String methodName = request.getMethod();
     
    7069                                        channel.basicPublish("", props.getReplyTo(), replyProps, bytesResponse);
    7170
    72                                         Log.saveLog("Server-Serialize", bytesResponse);
     71                                        //Log.saveLog("Server-Serialize", bytesResponse);
    7372                                }
    7473
Note: See TracChangeset for help on using the changeset viewer.