Package org.mockejb.jms

Examples of org.mockejb.jms.MockTopic

70
71
72
73
74
75
76
77
78
        final StatusConsoleListener l = new StatusConsoleListener(Level.ERROR);
        StatusLogger.getLogger().registerListener(l);
        MockContextFactory.setAsInitial();
        context = new InitialContext();
        context.rebind(FACTORY_NAME, new TopicConnectionFactoryImpl() );
        context.rebind(TOPIC_NAME, new MockTopic(TOPIC_NAME) );
        ((LoggerContext) LogManager.getContext()).reconfigure();
        receiver = new JMSTopicReceiver(FACTORY_NAME, TOPIC_NAME, null, null);
    }
View Full Code Here
265
266
267
268
269
270
271
272
273
274
275
    }
   
    public void executeSessionTopicSubscriberRetry(final boolean wsmq)
        throws Exception
    {
        final Topic topic = new MockTopic(TOPIC_NAME) ;
        final JmsConnectionPool pool = new JmsConnectionPool(getPoolEnv()) ;
        final JmsSession session = pool.getSession() ;
        Assert.assertEquals("Session class", JmsSession.class, session.getClass()) ;
       
        final TopicSubscriber topicSubscriber = session.createDurableSubscriber(topic, "testSessionTopicSubscriberRetry") ;
View Full Code Here
536
537
538
539
540
541
542
543
544
545
546
    {
        final TransactionStrategy transactionStrategy = TransactionStrategy.getTransactionStrategy(true) ;
        TransactionStrategy.setTransactionStrategy(new MockActiveTransactionStrategy()) ;
        try
        {
            final Topic topic = new MockTopic(TOPIC_NAME) ;
            final JmsConnectionPool pool = new JmsConnectionPool(getPoolEnv()) ;
            final JmsSession session = pool.getSession() ;
            Assert.assertEquals("Session class", JmsXASession.class, session.getClass()) ;
           
            final TopicSubscriber topicSubscriber = session.createDurableSubscriber(topic, "testSessionTopicSubscriberRetry") ;
View Full Code Here
169
170
171
172
173
174
175
176
177
178
179
   
    topicEl.setAttribute(NotifyJMS.ATT_DEST_NAME, topicName);
  }

  private MockTopic createAndBindTopic(String topicName) throws NamingException, NamingContextException {
    MockTopic mockTopic = new MockTopic(topicName);
   
    final Context ctx = NamingContextPool.getNamingContext(null) ;
    try
    {
        ctx.rebind(topicName, mockTopic);
View Full Code Here
218
219
220
221
222
223
224
225
226
227
228
    return mockQueue;
  }

  @SuppressWarnings("unused")
  private MockTopic createAndBindTopic(String topicName) throws NamingException, NamingContextException {
    MockTopic mockTopic = new MockTopic(topicName);
   
    final Context ctx = NamingContextPool.getNamingContext(null);
    try
    {
        ctx.rebind(topicName, mockTopic);
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
        try
        {
            ctx.rebind(CONNECTION_FACTORY, new MockQueueConnectionFactory());
            ctx.rebind(TOPIC_CONNECTION_FACTORY, new MockTopicConnectionFactory());
            ctx.rebind(QUEUE_NAME, new MockQueue(QUEUE_NAME));
            ctx.rebind(TOPIC_NAME, new MockTopic(TOPIC_NAME));
        }
        finally
        {
            NamingContextPool.releaseNamingContext(ctx) ;
        }
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
        assertTrue("Incorrect event", "Test Message".equals(events.get(0).getMessage().getFormattedMessage()));
    }

    @Test
    public void testReconnect() throws Exception {
        context.rebind(TOPIC_NAME, new MockTopic(TOPIC_NAME));
        final AbstractJMSReceiver receiver = new JMSTopicReceiver(FACTORY_NAME, TOPIC_NAME, null, null);
        ThreadContext.put("appender", "Failover");
        final Logger logger = LogManager.getLogger(JMSTopicFailoverTest.class);
        logger.debug("Test Message");
        final List<LogEvent> events = app.getEvents();
View Full Code Here
69
70
71
72
73
74
75
76
77
        final StatusConsoleListener l = new StatusConsoleListener(Level.ERROR);
        StatusLogger.getLogger().registerListener(l);
        MockContextFactory.setAsInitial();
        context = new InitialContext();
        context.rebind(FACTORY_NAME, new TopicConnectionFactoryImpl() );
        context.rebind(TOPIC_NAME, new MockTopic(TOPIC_NAME) );
        ((LoggerContext) LogManager.getContext()).reconfigure();
        receiver = new JMSTopicReceiver(FACTORY_NAME, TOPIC_NAME, null, null);
    }
View Full Code Here
68
69
70
71
72
73
74
75
76
        final StatusConsoleListener l = new StatusConsoleListener(Level.ERROR);
        StatusLogger.getLogger().registerListener(l);
        MockContextFactory.setAsInitial();
        context = new InitialContext();
        context.rebind(FACTORY_NAME, new TopicConnectionFactoryImpl() );
        context.rebind(TOPIC_NAME, new MockTopic(TOPIC_NAME) );
        ((LoggerContext) LogManager.getContext()).reconfigure();
        receiver = new JMSTopicReceiver(FACTORY_NAME, TOPIC_NAME, null, null);
    }
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
        assertTrue("Incorrect event", "Test Message".equals(events.get(0).getMessage().getFormattedMessage()));
    }

    @Test
    public void testReconnect() throws Exception {
        context.rebind(TOPIC_NAME, new MockTopic(TOPIC_NAME));
        final AbstractJMSReceiver receiver = new JMSTopicReceiver(FACTORY_NAME, TOPIC_NAME, null, null);
        ThreadContext.put("appender", "Failover");
        final Logger logger = LogManager.getLogger(JMSTopicFailoverTest.class);
        logger.debug("Test Message");
        final List<LogEvent> events = app.getEvents();
View Full Code Here
TOP

Related Classes of org.mockejb.jms.MockTopic

  • org.apache.logging.log4j.core.net.JMSTopicFailoverTest
  • org.apache.logging.log4j.core.net.JMSTopicTest
  • org.jboss.internal.soa.esb.rosetta.pooling.JmsConnectionPoolUnitTest
  • org.jboss.soa.esb.actions.routing.JMSRouterUnitTest
  • org.jboss.soa.esb.notification.NotifyQueuesUnitTest
  • org.jboss.soa.esb.notification.NotifyTopicsUnitTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.