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.objectweb.joram.client.jms.admin.ClusterQueue.addDestination()

    ictx.bind("queue1", queue1);
    ictx.bind("queue2", queue2);


    ClusterQueue clusterQueue = new ClusterQueue();
    clusterQueue.addDestination("server0", queue0);
    clusterQueue.addDestination("server1", queue1);
    clusterQueue.addDestination("server2", queue2);
    clusterQueue.setFreeReading();
    clusterQueue.setFreeWriting();
    ictx.rebind("clusterQueue", clusterQueue);

View Full Code Here

Examples of org.objectweb.joram.client.jms.admin.ClusterQueue.addDestination()

    ictx.bind("queue2", queue2);


    ClusterQueue clusterQueue = new ClusterQueue();
    clusterQueue.addDestination("server0", queue0);
    clusterQueue.addDestination("server1", queue1);
    clusterQueue.addDestination("server2", queue2);
    clusterQueue.setFreeReading();
    clusterQueue.setFreeWriting();
    ictx.rebind("clusterQueue", clusterQueue);


    System.out.println("clusterQueue = " + clusterQueue);

View Full Code Here

Examples of org.objectweb.joram.client.jms.admin.ClusterTopic.addDestination()

    ictx.bind("topic0", topic0);
    ictx.bind("topic1", topic1);
    ictx.bind("topic2", topic2);


    ClusterTopic clusterTopic = new ClusterTopic();
    clusterTopic.addDestination("server0", topic0);
    clusterTopic.addDestination("server1", topic1);
    clusterTopic.addDestination("server2", topic2);
    clusterTopic.setFreeReading();
    clusterTopic.setFreeWriting();
    ictx.rebind("clusterTopic", clusterTopic);

View Full Code Here

Examples of org.objectweb.joram.client.jms.admin.ClusterTopic.addDestination()

    ictx.bind("topic1", topic1);
    ictx.bind("topic2", topic2);


    ClusterTopic clusterTopic = new ClusterTopic();
    clusterTopic.addDestination("server0", topic0);
    clusterTopic.addDestination("server1", topic1);
    clusterTopic.addDestination("server2", topic2);
    clusterTopic.setFreeReading();
    clusterTopic.setFreeWriting();
    ictx.rebind("clusterTopic", clusterTopic);

View Full Code Here

Examples of org.objectweb.joram.client.jms.admin.ClusterTopic.addDestination()

    ictx.bind("topic2", topic2);


    ClusterTopic clusterTopic = new ClusterTopic();
    clusterTopic.addDestination("server0", topic0);
    clusterTopic.addDestination("server1", topic1);
    clusterTopic.addDestination("server2", topic2);
    clusterTopic.setFreeReading();
    clusterTopic.setFreeWriting();
    ictx.rebind("clusterTopic", clusterTopic);


    System.out.println("clusterTopic = " + clusterTopic);

View Full Code Here

Examples of org.pentaho.actionsequence.dom.IActionSequenceOutput.addDestination()

        input.addSource( "request", parameterName );
      }
    }


    IActionSequenceOutput outputStreamOutput = actionSequenceDocument.createOutput( "outputstream", CONTENT_TYPE ); //$NON-NLS-1$
    outputStreamOutput.addDestination( RESPONSE_OUTPUT_DESTINATION, "content" ); //$NON-NLS-1$


    MQLAction mqlAction = (MQLAction) actionSequenceDocument.addAction( MQLAction.class );
    mqlAction.setActionInputValue( "query", queryInput ); //$NON-NLS-1$


    // add inputs from parameterNameSet to this action

View Full Code Here

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


      log.info("TEST 1: Testing filtered PtP message");
      String content = "12345678901"; // content is too long, our plugin denies this message
      try {
         PublishQos pq = new PublishQos(glob);
         pq.addDestination(new Destination(new SessionName(glob, name)));
         PublishReturnQos rq = con.publish(new MsgUnit("<key oid='MSG'/>", content.getBytes(), pq.toXml()));
         log.info("TEST 1: SUCCESS returned state=" + rq.getState());
         assertTrue("Return OK", !Constants.STATE_OK.equals(rq.getState()));
      } catch(XmlBlasterException e) {
         log.warning("XmlBlasterException: " + e.getMessage());

View Full Code Here

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


      log.info("TEST 2: Testing unfiltered PtP message");
      content = "1234567890";
      try {
         PublishQos pq = new PublishQos(glob);
         pq.addDestination(new Destination(new SessionName(glob, name)));
         PublishReturnQos rq = con.publish(new MsgUnit("<key oid='MSG'/>", content.getBytes(), pq.toXml()));
         assertEquals("Return not OK", Constants.STATE_OK, rq.getState());
         log.info("TEST 2: SUCCESS");
      } catch(XmlBlasterException e) {
         log.warning("XmlBlasterException: " + e.getMessage());

View Full Code Here

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

      }


      log.info("TEST 3: Test what happens if the plugin throws an exception");
      try {   // see THROW_EXCEPTION_FOR_LEN=3
         PublishQos pq = new PublishQos(glob);
         pq.addDestination(new Destination(new SessionName(glob, name)));
         con.publish(new MsgUnit("<key oid='MSG'/>", "123".getBytes(), pq.toXml()));
         fail("publish - expected an XmlBlasterException");
      } catch(XmlBlasterException e) {
         log.warning("TEST 3: SUCCESS XmlBlasterException: " + e.getMessage());
      }

View Full Code Here

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

            PublishQos pq = new PublishQos(glob);
            pq.setPriority(PriorityEnum.NORM_PRIORITY);
            pq.setPersistent(true);
            Destination dest = new Destination(glob, new SessionName(glob, sessionNameRcv));
            dest.forceQueuing(true);
            pq.addDestination(dest);
            pq.setForceUpdate(true);
            pq.setSubscribable(false);
            pq.setLifeTime(60000L);
            
            if (i == 0) {

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.