Back Forum Reply New

JmsTemplate with Tibco Queue

:1550lt;/propgt;    lt;prop key=quot;java.naming.security.principalquot;gt;...lt;/propgt;    lt;prop key=quot;java.naming.security.credentialsquot;gt;...lt;/propgt;lt;/propsgt;       lt;/propertygt;   lt;/beangt;
   lt;!-- JMS Topic Connection Factory --gt;   lt;bean id=quot;internalJmsQueueConnectionFactoryquot;  class=quot;org..jndi.JndiObjectFactoryBeanquot;gt;       lt;property name=quot;jndiTemplatequot; ref=quot;jndiTemplatequot;/gt;       lt;property name=quot;jndiNamequot; value=quot;QueueConnectionFactoryquot; /gt;   lt;/beangt;
lt;bean id=quot;authJmsQueueConnectionFactoryquot; class=quot;org..jms.connection.UserCredentialsConnectionFactoryAdapterquot;gt;  lt;property name=quot;targetConnectionFactoryquot; ref=quot;internalJmsQueueConnectionFactoryquot; /gt;  lt;property name=quot;usernamequot; value=quot;...quot; /gt;  lt;property name=quot;passwordquot; value=quot;...quot; /gt; lt;/beangt;
   lt;!-- JMS Destination Resolver --gt;   lt;bean id=quot;jmsDestinationResolverquot; class=quot;org..jms.support.destination.JndiDestinationResolverquot;gt;       lt;property name=quot;jndiTemplatequot; ref=quot;jndiTemplatequot; /gt;       lt;property name=quot;cachequot; value=quot;truequot; /gt;   lt;/beangt;          lt;bean id=quot;jmsQueueTemplatequot; class=quot;org..jms.core.JmsTemplatequot;gt;       lt;property name=quot;connectionFactoryquot; ref=quot;authJmsQueueConnectionFactoryquot; /gt;       lt;property name=quot;destinationResolverquot; ref=quot;jmsDestinationResolverquot; /gt;       lt;property name=quot;defaultDestinationNamequot; value=quot;int.q.to.testquot; /gt;       lt;property name=quot;receiveTimeoutquot; value=quot;20000quot; /gt;   lt;/beangt;Code:
public class SpringJMS {
   public static void main(String[] args) throws InterruptedException, IOException {          ApplicationContext context = new FileSystemXmlApplicationContext(quot;/conf/SpringJMS-context.xmlquot;);              JmsTemplate t = (JmsTemplate)context.getBean(quot;jmsQueueTemplatequot;);              t.send(new MessageCreator() {

@Override
public Message createMessage(Session s) throws JMSException {
TextMessage tm = s.createTextMessage();

tm.setText(quot;Sample Messagequot;);

return tm;
}
});          }
}
¥
Back Forum Reply New