Package org.xmlBlaster.util.qos

Examples of org.xmlBlaster.util.qos.ConnectQosData

1733
1734
1735
1736
1737
1738
1739
1740
1741
1742
1743
1744
1745
      SessionInfo sessionInfo = clientEvent.getSessionInfo();
      SessionName sessionName = sessionInfo.getSessionName();
     
      try {
         ConnectQosData cd = sessionInfo.getConnectQos().getData();
         // A client can on connect send a event/disconnect=false clientProperty to suppress the event fired
         if (cd.getClientProperty(ContextNode.EVENT_MARKER_TAG + ContextNode.SEP + "disconnect", true) == false) {
            if (log.isLoggable(Level.FINE))  log.fine("Found " + ContextNode.EVENT_MARKER_TAG + ContextNode.SEP + "disconnect=true for "+sessionName.toString());
          return;
         }
      }
      catch (Throwable e) {
View Full Code Here
2310
2311
2312
2313
2314
2315
2316
2317
2318
2319
2320
2321
2322
2323
         //dispatchManager.getDispatchConnectionsHandler().getCurrentDispatchConnection().getSessionInfoProtector().getConnectQos();
       //log.severe("Debug only: lookup " + sessionName.toString());
         CbDispatchConnection cbd = (CbDispatchConnection)dispatchManager.getDispatchConnectionsHandler().getCurrentDispatchConnection();
         if (cbd != null) {
            I_AdminSession is = cbd.getAdminSession();
            ConnectQosData cd = is.getConnectQos().getData();
            //ConnectQosData cd = clientEvent.getSessionInfo().getConnectQos().getData();
            // A client can on connect send a event/callbackState=false clientProperty to suppress the event fired
            if (cd.getClientProperty(ContextNode.EVENT_MARKER_TAG + ContextNode.SEP + "callbackState", true) == false) {
               if (log.isLoggable(Level.FINE))  log.fine("Found " + ContextNode.EVENT_MARKER_TAG + ContextNode.SEP + "callbackState=true for "+sessionName.toString());
             return;
            }
           //else
           //    log.severe("Debug only: Not found " + ContextNode.EVENT_MARKER_TAG + ContextNode.SEP + "callbackState");
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
            if (obj.length != 1) {
               throw new XmlBlasterException(glob, ErrorCode.INTERNAL_ILLEGALARGUMENT, ME,
                  "Expected 1 entries in serialized object '" + type + "' but got " + obj.length + " for priority=" + priority + " timestamp=" + timestamp + ". Could be a version incompatibility.");
            }
            String qos = (String)obj[0];
            ConnectQosData connectQosData = glob.getConnectQosFactory().readObject(qos);
            return new MsgQueueConnectEntry(glob, PriorityEnum.toPriorityEnum(priority), storageId,
                                            new Timestamp(timestamp), sizeInBytes, connectQosData);
         }
         else if (methodName == MethodName.DISCONNECT) {
            if (obj.length != 1) {
View Full Code Here
252
253
254
255
256
257
258
259
260
261
262
         }
         else if (methodName == MethodName.GET) {
            throw new XmlBlasterException(glob, ErrorCode.INTERNAL_NOTIMPLEMENTED, ME, "Object '" + type + "' not implemented, you can't use synchronous GET requests in queues.");
         }
         else if (methodName == MethodName.CONNECT) {
            ConnectQosData connectQosData = glob.getConnectQosFactory().readObject(qos);
            return new MsgQueueConnectEntry(glob, PriorityEnum.toPriorityEnum(priority), storageId,
                                            new Timestamp(timestamp), sizeInBytes, connectQosData);
         }
         else if (methodName == MethodName.DISCONNECT) {
            DisconnectQos disconnectQos = new DisconnectQos(glob, glob.getDisconnectQosFactory().readObject(qos));
View Full Code Here
TOP

Related Classes of org.xmlBlaster.util.qos.ConnectQosData

  • org.xmlBlaster.authentication.plugins.I_ClientPlugin
  • org.xmlBlaster.authentication.plugins.I_SecurityQos
  • org.xmlBlaster.client.dispatch.ClientDispatchConnection
  • org.xmlBlaster.client.filepoller.Publisher
  • org.xmlBlaster.client.qos.ConnectQos
  • org.xmlBlaster.client.queuemsg.ClientEntryFactory
  • org.xmlBlaster.client.script.XmlScriptClient
  • org.xmlBlaster.contrib.filewatcher.Publisher
  • org.xmlBlaster.contrib.filewriter.FileWriter
  • org.xmlBlaster.engine.cluster.ClusterNode
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.