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()

         }


         // 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, 3000, 1);
         assertEquals("Missing reply message.", 1, replies.length);
         assertEquals("On doubt no ultimate truth, my dear.", replies[0].getContentStr());
         log.info(senderName+": Got " + replies.length + " reply :\n" + replies[0].toXml());

View Full Code Here

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

            pk.setDomain("RUGBY_NEWS"); // heron is master: need for routing as heron is not directly connected to us
            PublishQos pq = new PublishQos(glob);
            SessionName sessionName = heronCon.getConnectReturnQos().getSessionName(); // destination client
            Destination destination = new Destination(sessionName);
            destination.forceQueuing(true);
            pq.addDestination(destination);
            log.info("Sending PtP message '" + oid + "' from bilbo to '" + sessionName + "' :" + pq.toXml());
            MsgUnit msgUnit = new MsgUnit(pk, (contentStr+"-"+i).getBytes(), pq);
            PublishReturnQos prq = bilboCon.publish(msgUnit);
            log.info("Published message to destination='" + sessionName +
                                       "' content='" + (contentStr+"-"+i) +

View Full Code Here

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

      if (oid != null) key.setOid(oid);
      key.setClientTags("<airport/>");
      PublishQos qos = new PublishQos(glob);
      qos.setPersistent(true);
      qos.setVolatile(true);
      qos.addDestination(new Destination(new SessionName(this.glob, "joe")));
      MsgUnit msgUnit = new MsgUnit(key, content, qos);


      this.glob.getXmlBlasterAccess().publish(msgUnit);
      if (doGc) Util.gc(2);
      try {

View Full Code Here

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

            if (xbDest.getForceQueuing())
               ptpDest.forceQueuing(true);
            qos = new PublishQos(global, ptpDest);
            for (int i=1; i < ptpNames.length; i++) {
               org.xmlBlaster.util.qos.address.Destination additionalDest = new org.xmlBlaster.util.qos.address.Destination(global, new SessionName(global, ptpNames[i]));
               qos.addDestination(additionalDest);
            }
         }
         else {
            qos = new PublishQos(global);
         }

View Full Code Here

Examples of org.xmlBlaster.util.qos.MsgQosData.addDestination()


      assertNull("", qos.getDestinations());
      assertEquals("", 0, qos.getNumDestinations());
      assertEquals("", 0, qos.getDestinationArr().length);


      qos.addDestination(destination);
      assertNotNull("", qos.getDestinations());
      assertEquals("", 1, qos.getDestinations().size());
      assertEquals("", 1, qos.getNumDestinations());
      assertEquals("", 1, qos.getDestinationArr().length);

View Full Code Here

Examples of se.sics.cooja.RadioConnection.addDestination()

            }
          }


        } else {
          /* Success: radio starts receiving */
          newConnection.addDestination(recv);
        }
      } else if (distance <= moteInterferenceRange) {
        /* Within interference range */
        newConnection.addInterfered(recv);
        recv.interfereAnyReception();

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.