Examples of DispatchStatistic

org.xmlBlaster.util.dispatch.DispatchStatistic
Collecting data on how many messages / bytes are successfully delivered.

Examples of org.xmlBlaster.util.dispatch.DispatchStatistic

         */
         if (log.isLoggable(Level.FINE)) log.fine("Received message [" + updateKey.getOid() + "] from publisher " + updateQos.getSender());


         String ret = update(cbSessionId, updateKey, content, updateQos);


         DispatchStatistic statistic = getDispatchStatistic();
         if (statistic != null) statistic.incrNumUpdate(1);
         
         // export (encrypt) return value
         if (secPlgn != null) {
            MsgUnitRaw msg = new MsgUnitRaw(null, (byte[])null, ret);
            CryptDataHolder dataHolder = new CryptDataHolder(MethodName.UPDATE, msg, null);

View Full Code Here

Examples of org.xmlBlaster.util.dispatch.DispatchStatistic

         UpdateQos updateQos = new UpdateQos(glob, updateQosLiteral);
         if (log.isLoggable(Level.FINE)) log.fine("Received message [" + updateKey.getOid() + "] from publisher " + updateQos.getSender());


         update(cbSessionId, updateKey, content, updateQos);


         DispatchStatistic statistic = getDispatchStatistic();
         if (statistic != null) statistic.incrNumUpdateOneway(1);
      }
      catch (Throwable e) {
         log.severe("Caught exception, can't deliver it to xmlBlaster server as we are in oneway mode: " + e.toString());
      }
   }

View Full Code Here

Examples of org.xmlBlaster.util.dispatch.DispatchStatistic

         synchronized (this) {
            if (this.statistic == null) {
               if (this.dispatchManager != null)
                  this.statistic = this.dispatchManager.getDispatchStatistic();
               else
                  this.statistic = new DispatchStatistic();
            }
         }
      }
      return this.statistic;
   }

View Full Code Here

Examples of org.xmlBlaster.util.dispatch.DispatchStatistic

      String instanceName = this.glob.validateJmxValue(this.subjectName.getLoginName());
      this.contextNode = new ContextNode(ContextNode.SUBJECT_MARKER_TAG, instanceName,
                                       this.glob.getContextNode());


      this.ME = this.instanceId + "-" + this.subjectName.getAbsoluteName();
      this.dispatchStatistic = new DispatchStatistic();


      // JMX register "client/joe"
      this.mbeanHandle = this.glob.registerMBean(this.contextNode, this.subjectInfoProtector);


      if (log.isLoggable(Level.FINE)) log.fine(ME+": Created new SubjectInfo");

View Full Code Here

Examples of org.xmlBlaster.util.dispatch.DispatchStatistic

            if (this.statistic == null) {
               DispatchManager dispatchManager = this.dispatchManager;
               if (dispatchManager != null)
                  this.statistic = dispatchManager.getDispatchStatistic();
               else
                  this.statistic = new DispatchStatistic();
            }
         }
      }
      return this.statistic;
   }

View Full Code Here

TOP

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.