List of addDestination() Examples

Examples of addDestination()

flex.management.runtime.messaging.services.ServiceControl.addDestination()
Adds the ObjectName of a destination registered with the managed service. @param value The ObjectName of a destination registered with the managed service.
flex.messaging.services.HTTPProxyService.addDestination()
Casts the Destination into HTTPProxyDestination and calls super.addDestination. @param destination The Destination instance to be added.
org.apache.activemq.broker.Broker.addDestination()
org.contikios.cooja.RadioConnection.addDestination()
Add (non-interfered) destination radio to connection. @param radio Radio
org.exolab.jms.administration.JmsAdminServerIfc.addDestination()
Add a specific destination with the specified name @param name destination name @param queue whether it is queue or a topic @return boolean true if successful @exception JMSException
org.exolab.jms.persistence.PersistenceAdapter.addDestination()
Add a new destination to the database. @param connection - the connection to use @param name - the destination name @param queue - true if it pertains to a queue @throws PersistenceException
org.objectweb.joram.client.jms.admin.ClusterQueue.addDestination()
org.objectweb.joram.client.jms.admin.ClusterTopic.addDestination()
org.pentaho.actionsequence.dom.IActionSequenceOutput.addDestination()
org.xmlBlaster.client.qos.PublishQos.addDestination()
Add a destination where to send the message.
Note you can invoke this multiple times to send to multiple destinations.
Note that the default lifeTime is set to 0 (PtP are volatile messages as default) @param destination The loginName of a receiver or some destination XPath query
org.xmlBlaster.util.qos.MsgQosData.addDestination()
Add a destination. Note that the default lifeTime is set to 0 (PtP are volatile as default)
se.sics.cooja.RadioConnection.addDestination()
Adds destination radio. @param radio Radio

Examples of org.xmlBlaster.client.qos.PublishQos.addDestination()

         {
            log.info("============ STEP 4: Publish PtP message which is NOT subscribable");
            PublishKey pk = new PublishKey(globSnd, oid, "text/xml", "1.0");
            PublishQos pq = new PublishQos(globSnd);
            Destination dest = new Destination(globSnd, new SessionName(globSnd, sessionNameRcv));
            pq.addDestination(dest);
            pq.setSubscribable(false);
            byte[] content = "Hello".getBytes();
            MsgUnit msgUnit = new MsgUnit(pk, content, pq);
            PublishReturnQos prq = conSnd.publish(msgUnit);
            log.info("Got status='" + prq.getState() + "' rcvTimestamp=" + prq.getRcvTimestamp().toString() +

View Full Code Here

Examples of org.xmlBlaster.client.qos.PublishQos.addDestination()

         {
            log.info("============ STEP 5: Publish PtP message which IS subscribable");
            PublishKey pk = new PublishKey(globSnd, oid, "text/xml", "1.0");
            PublishQos pq = new PublishQos(globSnd);
            Destination dest = new Destination(globSnd, new SessionName(globSnd, sessionNameRcv));
            pq.addDestination(dest);
            pq.setSubscribable(true);
            byte[] content = "Hello".getBytes();
            MsgUnit msgUnit = new MsgUnit(pk, content, pq);
            PublishReturnQos prq = conSnd.publish(msgUnit);
            log.info("Got status='" + prq.getState() + "' rcvTimestamp=" + prq.getRcvTimestamp().toString() +

View Full Code Here

Examples of org.xmlBlaster.client.qos.PublishQos.addDestination()

         PublishQos qos = null;
         if (destination != null) {
            qos = new PublishQos(this.glob, destination);
            if (additionalDestinations != null) {
               for (int i=0; i < additionalDestinations.size(); i++)
                  qos.addDestination((Destination)additionalDestinations.get(i));
            }
         }
         else
            qos = new PublishQos(this.glob);
         qos.setSubscribable(true);

View Full Code Here

Examples of org.xmlBlaster.client.qos.PublishQos.addDestination()

         }


         // Send a message to 'receiver' and block for the reply
         PublishKey pk = new PublishKey(sender.getGlobal(), "requestForEnlightenment");
         PublishQos pq = new PublishQos(sender.getGlobal());
         pq.addDestination(new Destination(new SessionName(sender.getGlobal(), receiverName)));
         MsgUnit msgUnit = new MsgUnit(pk, "Tell me the truth!", pq);
         MsgUnit[] replies = sender.request(msgUnit, 6000, 1);
         if (replies.length > 0)
            log.info(senderName+": Got " + replies.length + " reply :\n" + replies[0].toXml());
         else

View Full Code Here

Examples of org.xmlBlaster.client.qos.PublishQos.addDestination()


            if (destination != null) {
               log.fine("Using destination: '" + destination + "'");
               Destination dest = new Destination(glob, new SessionName(glob, destination));
               dest.forceQueuing(forceQueuing);
               pq.addDestination(dest);
            }


            byte[] content;
            if (contentSize >= 0) {
               content = new byte[contentSize];

View Full Code Here

Examples of org.xmlBlaster.client.qos.PublishQos.addDestination()

                  if (updateQos.isErased()) return "";
                  try {
                     // Send an ACK back ...
                     PublishKey pk = new PublishKey(receiver.getGlobal(), "HelloWorld5:ACK", "text/plain", "1.0");
                     PublishQos pq = new PublishQos(receiver.getGlobal());
                     pq.addDestination(new Destination(updateQos.getSender()));
                     MsgUnit msgUnit = new MsgUnit(pk, "ACK", pq);
                     boolean oneway = false; // just for demo, you can try a variant with never blocking oneway
                     if (oneway) {
                        MsgUnit[] arr = new MsgUnit[1];
                        arr[0] = msgUnit;

View Full Code Here

Examples of org.xmlBlaster.client.qos.PublishQos.addDestination()

         }


         // Send a message to 'receiver'
         PublishKey pk = new PublishKey(sender.getGlobal(), "HelloWorld5", "text/plain", "1.0");
         PublishQos pq = new PublishQos(sender.getGlobal());
         pq.addDestination(new Destination(new SessionName(sender.getGlobal(), receiverName)));
         MsgUnit msgUnit = new MsgUnit(pk, "Hi", pq);
         PublishReturnQos retQos = sender.publish(msgUnit);
         log.info("Published message '" + retQos.getKeyOid() + "' to " + receiverName + ":\n" + msgUnit.toXml());
      }
      catch (XmlBlasterException e) {

View Full Code Here

Examples of org.xmlBlaster.client.qos.PublishQos.addDestination()

    */
   public final void sendPtPMessage(MsgQueueEntry entry, String pluginName, String action, String currStatus) throws XmlBlasterException {
      SessionName receiver = entry.getSender();  // Send back (receiver==sender)
      if (log.isLoggable(Level.FINE)) log.fine("Sending PtP notification about special message treatment in plugin, dispatcher state=" + currStatus + " receiver '" + receiver + "' ...");
      PublishQos pq = new PublishQos(glob);
      pq.addDestination(new Destination(receiver)); 
      pq.setSender(new SessionName(glob, getLoginName())); // Set ourself as sender
      pq.setSubscribable(false); // For the time being we don't allow others to subscribe on the PtP notification
      pq.setState(action);
      pq.setStateInfo("Notification about special message treatment in plugin " + pluginName + ", dispatcher state=" + currStatus);
      MsgUnit msgUnit = new MsgUnit(glob, "<key oid='" + entry.getKeyOid() + "'/>", "", pq.toXml());

View Full Code Here

Examples of org.xmlBlaster.client.qos.PublishQos.addDestination()

         msgSequenceNumber++;
         String content = "" + msgSequenceNumber;
         
         PublishQos pq = new PublishQos(glob);
         for(int i=0; i<sessionNameArr.length; i++)
            pq.addDestination(new Destination(sessionNameArr[i]));
         
         MsgUnit msgUnit = new MsgUnit("<key oid='"+oid+"'/>", content.getBytes(), pq.toXml());


         PublishReturnQos rq = conHolder.con.publish(msgUnit);

View Full Code Here

Examples of org.xmlBlaster.client.qos.PublishQos.addDestination()

         PublishQos publishQos = new PublishQos(glob);
         msgUnit = new MsgUnit(msgUnit, null, null, publishQos.getData());
         if (ptp) {
            PublishKey pk = new PublishKey(glob);
            PublishQos pq = new PublishQos(glob);
            pq.addDestination(new Destination(new SessionName(glob, secondName)));
            msgUnit = new MsgUnit(msgUnit, pk.getData(), null, pq.getData());
         }
         publishOid = callbackConnection.publish(msgUnit).getKeyOid();
         log.info("Success: Publish " + msgUnit.getKey() + " done");
         if (!ptp)

View Full Code Here

0 1 2 3

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.