List of resolveDestinationName() Examples

Examples of resolveDestinationName()

org.springframework.jms.support.destination.DestinationResolver.resolveDestinationName()
Resolve the given destination name, either as located resource or as dynamic destination. @param session the current JMS Session(may be null if the resolver implementation is able to work without it) @param destinationName the name of the destination @param pubSubDomain true if the domain is pub-sub, false if P2P @return the JMS destination (either a topic or a queue) @throws javax.jms.JMSException if the JMS Session failed to resolve the destination @throws DestinationResolutionException in case of general destination resolution failure

Examples of org.springframework.jms.support.destination.DestinationResolver.resolveDestinationName()

    Destination destination = new StubQueue();


    MockControl control = MockControl.createControl(DestinationResolver.class);
    DestinationResolver destinationResolver = (DestinationResolver) control.getMock();


    destinationResolver.resolveDestinationName(null, "destinationname", false);
    control.setReturnValue(destination);
    control.replay();


    DefaultJmsActivationSpecFactory activationSpecFactory = new DefaultJmsActivationSpecFactory();
    activationSpecFactory.setDestinationResolver(destinationResolver);

View Full Code Here

Examples of org.springframework.jms.support.destination.DestinationResolver.resolveDestinationName()

            public void run() {
                @SuppressWarnings("unchecked")
                Destination destination = (Destination)jmsTemplate.execute(new SessionCallback() {
                    public Object doInJms(Session session) throws JMSException {
                        DestinationResolver resolv = jmsTemplate.getDestinationResolver();
                        return resolv.resolveDestinationName(session, jmsConfig.getTargetDestination(),
                                                             false);
                    }
                });
                
                final Message message = jmsTemplate.receive(destination);

View Full Code Here

Examples of org.springframework.jms.support.destination.DestinationResolver.resolveDestinationName()

                    
                @SuppressWarnings("unchecked")
                Destination destination2 = (Destination)jmsTemplate.execute(new SessionCallback() {
                    public Object doInJms(Session session) throws JMSException {
                        DestinationResolver resolv = jmsTemplate.getDestinationResolver();
                        return resolv.resolveDestinationName(session,
                                                             jmsConfig.getReplyDestination(),
                                                             false);
                    }
                });
                jmsTemplate.send(destination2, messageCreator);

View Full Code Here

Examples of org.springframework.jms.support.destination.DestinationResolver.resolveDestinationName()

            public void run() {
                @SuppressWarnings("unchecked")
                Destination destination = (Destination)jmsTemplate.execute(new SessionCallback() {
                    public Object doInJms(Session session) throws JMSException {
                        DestinationResolver resolv = jmsTemplate.getDestinationResolver();
                        return resolv.resolveDestinationName(session, jmsConfig.getTargetDestination(),
                                                             false);
                    }
                });
                
                final Message message = jmsTemplate.receive(destination);

View Full Code Here

Examples of org.springframework.jms.support.destination.DestinationResolver.resolveDestinationName()

                    
                @SuppressWarnings("unchecked")
                Destination destination2 = (Destination)jmsTemplate.execute(new SessionCallback() {
                    public Object doInJms(Session session) throws JMSException {
                        DestinationResolver resolv = jmsTemplate.getDestinationResolver();
                        return resolv.resolveDestinationName(session,
                                                             jmsConfig.getReplyDestination(),
                                                             false);
                    }
                });
                jmsTemplate.send(destination2, messageCreator);

View Full Code Here

Examples of org.springframework.jms.support.destination.DestinationResolver.resolveDestinationName()

    @SuppressWarnings("unchecked")
    private Destination resolveDestinationName(final JmsTemplate jmsTemplate, final String name) {
        SessionCallback sc = new SessionCallback() {
            public Object doInJms(Session session) throws JMSException {
                DestinationResolver resolv = jmsTemplate.getDestinationResolver();
                return resolv.resolveDestinationName(session, name, jmsConfig.isPubSubDomain());
            }
        };
        return (Destination)jmsTemplate.execute(sc);
    }

View Full Code Here

Examples of org.springframework.jms.support.destination.DestinationResolver.resolveDestinationName()


    private Destination resolveDestinationName(final JmsTemplate jmsTemplate, final String name) {
        SessionCallback<Destination> sc = new SessionCallback<Destination>() {
            public Destination doInJms(Session session) throws JMSException {
                DestinationResolver resolv = jmsTemplate.getDestinationResolver();
                return resolv.resolveDestinationName(session, name, jmsConfig.isPubSubDomain());
            }
        };
        return jmsTemplate.execute(sc);
    }

View Full Code Here

Examples of org.springframework.jms.support.destination.DestinationResolver.resolveDestinationName()

        Thread t = new Thread() {
            public void run() {
                Destination destination = jmsTemplate.execute(new SessionCallback<Destination>() {
                    public Destination doInJms(Session session) throws JMSException {
                        DestinationResolver resolv = jmsTemplate.getDestinationResolver();
                        return resolv.resolveDestinationName(session, jmsConfig.getTargetDestination(),
                                                             false);
                    }
                });
                
                final Message message = jmsTemplate.receive(destination);

View Full Code Here

Examples of org.springframework.jms.support.destination.DestinationResolver.resolveDestinationName()

                    
                Destination destination2 = jmsTemplate
                    .execute(new SessionCallback<Destination>() {
                        public Destination doInJms(Session session) throws JMSException {
                            DestinationResolver resolv = jmsTemplate.getDestinationResolver();
                            return resolv.resolveDestinationName(session,
                                                             jmsConfig.getReplyDestination(),
                                                             false);
                        }
                    });
                jmsTemplate.send(destination2, messageCreator);

View Full Code Here

Examples of org.springframework.jms.support.destination.DestinationResolver.resolveDestinationName()


    private Destination resolveDestinationName(final JmsTemplate jmsTemplate, final String name) {
        SessionCallback<Destination> sc = new SessionCallback<Destination>() {
            public Destination doInJms(Session session) throws JMSException {
                DestinationResolver resolv = jmsTemplate.getDestinationResolver();
                return resolv.resolveDestinationName(session, name, jmsConfig.isPubSubDomain());
            }
        };
        return jmsTemplate.execute(sc);
    }

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.