javax.jms.Destination#toString ( )源码实例Demo

@Override
public Object getProperty(JmsMessage message) throws JMSException {
    Destination dest = message.getFacade().getDestination();
    if (dest == null) {
        return null;
    }
    return dest.toString();
}
 

public void sendMessage(MessageContext messageContext,
        Destination destination, Message message) throws JMSException {
    String destinationName = destination.toString();

    if (destination instanceof Topic) {
        messageHandler.sendMessageToTopic(messageContext, destinationName,
                message);
    } else {
        messageHandler.sendMessageToQueue(messageContext, destinationName,
                message);
    }
}
 

public MessageConsumer createConsumer(Destination destination,
        ProxySession session) throws JMSException {
    String destinationName = destination.toString();
    ProxyMessageConsumer messageConsumer = new ProxyMessageConsumer(session);
    messageConsumer.setDestination(destination);

    if (destination instanceof Topic) {
        this.messageHandler.registerToTopic(destinationName,
                messageConsumer.getId());
    }

    return messageConsumer;
}
 

public void removeMessageConsumer(ProxyMessageConsumer messageConsumer)
        throws JMSException {
    Destination destination = messageConsumer.getDestination();

    if (destination instanceof Topic) {
        String destinationName = destination.toString();
        this.messageHandler.unregisterFromTopic(destinationName,
                messageConsumer.getId());
    }
}
 

public ConsumerThread(Session session, Destination destination, int threadNr) {
   super("Consumer " + destination.toString() + ", thread=" + threadNr);
   this.destination = destination;
   this.session = session;
}
 

public ProducerThread(Session session, Destination destination, int threadNr) {
   super("Producer " + destination.toString() + ", thread=" + threadNr);
   this.destination = destination;
   this.session = session;
}
 

@Override
public JmsDestination transform(Destination destination) throws JMSException {
    return new JmsQueue(destination.toString());
}