Examples of DestinationInfo

com.sun.messaging.jmq.util.admin.DestinationInfo
DestinationInfo encapsulates information about a JMQ Destination. It is used to pass this information between the Broker and an administration client.
com.tibco.tibjms.admin.DestinationInfo
io.fabric8.gateway.handlers.detecting.protocol.openwire.command.DestinationInfo
Used to create and destroy destinations on the broker. @openwire :marshaller code="8" @version $Revision: 1.9 $
org.apache.activemq.apollo.openwire.command.DestinationInfo
Used to create and destroy destinations on the broker. @openwire :marshaller code="8" @version $Revision: 1.9 $
org.apache.activemq.command.DestinationInfo
Used to create and destroy destinations on the broker. @openwire :marshaller code="8"
org.apache.geronimo.console.jmsmanager.DestinationInfo

Examples of org.apache.activemq.command.DestinationInfo

            dest = new ActiveMQTempTopic(info.getConnectionId(), tempDestinationIdGenerator.getNextSequenceId());
        } else {
            dest = new ActiveMQTempQueue(info.getConnectionId(), tempDestinationIdGenerator.getNextSequenceId());
        }


        DestinationInfo info = new DestinationInfo();
        info.setConnectionId(this.info.getConnectionId());
        info.setOperationType(DestinationInfo.ADD_OPERATION_TYPE);
        info.setDestination(dest);
        syncSendPacket(info);


        dest.setConnection(this);
        activeTempDestinations.put(dest, dest);
        return dest;

View Full Code Here

Examples of org.apache.activemq.command.DestinationInfo

            }
        }


        activeTempDestinations.remove(destination);


        DestinationInfo destInfo = new DestinationInfo();
        destInfo.setConnectionId(this.info.getConnectionId());
        destInfo.setOperationType(DestinationInfo.REMOVE_OPERATION_TYPE);
        destInfo.setDestination(destination);
        destInfo.setTimeout(0);
        syncSendPacket(destInfo);
    }

View Full Code Here

Examples of org.apache.activemq.command.DestinationInfo

    public void destroyDestination(ActiveMQDestination destination) throws JMSException {


        checkClosedOrFailed();
        ensureConnectionInfoSent();


        DestinationInfo info = new DestinationInfo();
        info.setConnectionId(this.info.getConnectionId());
        info.setOperationType(DestinationInfo.REMOVE_OPERATION_TYPE);
        info.setDestination(destination);
        info.setTimeout(0);
        syncSendPacket(info);


    }

View Full Code Here

Examples of org.apache.geronimo.console.jmsmanager.DestinationInfo

                }
                if (configURI.endsWith("\"")) {
                    configURI = configURI.substring(0, configURI.length() - 1);
                }


                DestinationInfo info = new DestinationInfo(adminObjectName,
                        (String) kernel.getAttribute(destinationName,
                                "PhysicalName"), type, destinationName
                                .getKeyProperty(NameFactory.J2EE_APPLICATION),
                        destinationName
                                .getKeyProperty(NameFactory.JCA_RESOURCE),

View Full Code Here

0 1 2 3 4 5

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.