[hornetq-commits] JBoss hornetq SVN: r8501 - trunk/tests/src/org/hornetq/tests/timing/core/client/impl.
do-not-reply at jboss.org
do-not-reply at jboss.org
Wed Dec 2 09:01:22 EST 2009
Author: timfox
Date: 2009-12-02 09:01:22 -0500 (Wed, 02 Dec 2009)
New Revision: 8501
Removed:
trunk/tests/src/org/hornetq/tests/timing/core/client/impl/ClientConsumerImplTest.java
Log:
deleted old easymock test
Deleted: trunk/tests/src/org/hornetq/tests/timing/core/client/impl/ClientConsumerImplTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/timing/core/client/impl/ClientConsumerImplTest.java 2009-12-02 13:20:31 UTC (rev 8500)
+++ trunk/tests/src/org/hornetq/tests/timing/core/client/impl/ClientConsumerImplTest.java 2009-12-02 14:01:22 UTC (rev 8501)
@@ -1,556 +0,0 @@
-/*
- * Copyright 2009 Red Hat, Inc.
- * Red Hat licenses this file to you under the Apache License, version
- * 2.0 (the "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- * http://www.apache.org/licenses/LICENSE-2.0
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- * implied. See the License for the specific language governing
- * permissions and limitations under the License.
- */
-package org.hornetq.tests.timing.core.client.impl;
-
-import org.hornetq.core.logging.Logger;
-import org.hornetq.tests.util.UnitTestCase;
-
-/**
- *
- * A ClientConsumerImplTest
- *
- * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
- *
- */
-public class ClientConsumerImplTest extends UnitTestCase
-{
- private static final Logger log = Logger.getLogger(ClientConsumerImplTest.class);
-
- public void testDummy()
- {
- }
-
-// public void testSetHandlerWhileReceiving() throws Exception
-// {
-// ClientSessionInternal session = EasyMock.createStrictMock(ClientSessionInternal.class);
-// ExecutorService executor = EasyMock.createStrictMock(ExecutorService.class);
-// Channel channel = EasyMock.createStrictMock(Channel.class);
-//
-// final ClientConsumerInternal consumer =
-// new ClientConsumerImpl(session, 123, 67576, false, executor, channel);
-//
-// MessageHandler handler = new MessageHandler()
-// {
-// public void onMessage(ClientMessage msg)
-// {
-// }
-// };
-//
-// Thread t = new Thread()
-// {
-// public void run()
-// {
-// try
-// {
-// consumer.receive(2000);
-// }
-// catch (Exception e)
-// {
-// }
-// }
-// };
-//
-// t.start();
-//
-// Thread.sleep(1000);
-//
-// try
-// {
-// consumer.setMessageHandler(handler);
-//
-// fail("Should throw exception");
-// }
-// catch (HornetQException e)
-// {
-// assertEquals(HornetQException.ILLEGAL_STATE, e.getCode());
-// }
-// finally
-// {
-// t.interrupt();
-// }
-// }
-//
-// public void testCloseWhileReceiving() throws Exception
-// {
-// ClientSessionInternal session = EasyMock.createStrictMock(ClientSessionInternal.class);
-// ExecutorService executor = EasyMock.createStrictMock(ExecutorService.class);
-// Channel channel = EasyMock.createStrictMock(Channel.class);
-//
-// final long clientTargetID = 283748;
-// final long targetID = 12934;
-// final long sessionTargetID = 23847327;
-//
-// final ClientConsumerInternal consumer =
-// new ClientConsumerImpl(session, targetID, clientTargetID, 787, false, pd, executor, cm);
-//
-// pd.unregister(clientTargetID);
-// session.removeConsumer(consumer);
-// EasyMock.expect(cm.sendCommandBlocking(targetID, new PacketImpl(PacketImpl.CLOSE))).andReturn(null);
-//
-// EasyMock.replay(session,cm, executor, pd);
-//
-// class ReceiverThread extends Thread
-// {
-// volatile boolean returned;
-// volatile ClientMessage msg;
-// volatile boolean failed;
-// public void run()
-// {
-// try
-// {
-// msg = consumer.receive();
-// returned = true;
-// }
-// catch (Exception e)
-// {
-// failed = true;
-// }
-// }
-// };
-//
-// ReceiverThread t = new ReceiverThread();
-//
-// t.start();
-//
-// Thread.sleep(2000);
-//
-// consumer.close();
-//
-// Thread.sleep(2000);
-//
-// assertTrue(t.returned);
-// assertNull(t.msg);
-// assertFalse(t.failed);
-//
-// t.join();
-//
-// EasyMock.verify(session, cm, executor, pd);
-// }
-//
-// public void testReceiveHandleMessagesAfterReceiveNoTimeout() throws Exception
-// {
-// testReceiveHandleMessagesAfterReceive(4000);
-// }
-//
-// public void testReceiveHandleMessagesAfterReceiveTimeout() throws Exception
-// {
-// testReceiveHandleMessagesAfterReceive(0);
-// }
-//
-// private void testReceiveHandleMessagesAfterReceive(final int timeout) throws Exception
-// {
-// ClientSessionInternal session = EasyMock.createStrictMock(ClientSessionInternal.class);
-// ExecutorService executor = EasyMock.createStrictMock(ExecutorService.class);
-// PacketDispatcher pd = EasyMock.createStrictMock(PacketDispatcher.class);
-// CommandManager cm = EasyMock.createStrictMock(CommandManager.class);
-//
-// final int numMessages = 10;
-//
-// final List<ClientMessage> msgs = new ArrayList<ClientMessage>();
-//
-// for (int i = 0; i < numMessages; i++)
-// {
-// ClientMessage msg = EasyMock.createStrictMock(ClientMessage.class);
-//
-// msgs.add(msg);
-//
-// EasyMock.expect(msg.getPriority()).andStubReturn((byte)4); //default priority
-//
-// EasyMock.expect(msg.isExpired()).andStubReturn(false);
-//
-// EasyMock.expect(msg.getDeliveryID()).andStubReturn((long)i);
-//
-// session.delivered((long)i, false);
-//
-// EasyMock.expect(msg.getEncodeSize()).andReturn(1);
-// }
-//
-// EasyMock.replay(session, cm, executor, pd);
-// EasyMock.replay(msgs.toArray());
-//
-// final ClientConsumerInternal consumer =
-// new ClientConsumerImpl(session, 675765, 67565, 787, false, pd, executor, cm);
-//
-// final long pause = 2000;
-//
-// class AdderThread extends Thread
-// {
-// volatile boolean failed;
-//
-// public void run()
-// {
-// try
-// {
-// Thread.sleep(pause);
-//
-// for (ClientMessage msg: msgs)
-// {
-// consumer.handleMessage(msg);
-// }
-// }
-// catch (Exception e)
-// {
-// log.error("Failed to add messages", e);
-// failed = true;
-// }
-// }
-// };
-//
-// AdderThread t = new AdderThread();
-//
-// t.start();
-//
-// for (int i = 0; i < numMessages; i++)
-// {
-// ClientMessage msg;
-//
-// if (timeout == 0)
-// {
-// msg = consumer.receive();
-// }
-// else
-// {
-// msg = consumer.receive(timeout);
-// }
-//
-// assertTrue(msg == msgs.get(i));
-// }
-//
-// assertNull(consumer.receiveImmediate());
-//
-// t.join();
-//
-// assertFalse(t.failed);
-//
-// EasyMock.verify(session, cm, executor, pd);
-// EasyMock.verify(msgs.toArray());
-//
-// assertEquals(0, consumer.getBufferSize());
-// }
-//
-// public void testReceiveHandleMessagesAfterReceiveWithTimeout() throws Exception
-// {
-// ClientSessionInternal session = EasyMock.createStrictMock(ClientSessionInternal.class);
-// ExecutorService executor = EasyMock.createStrictMock(ExecutorService.class);
-// PacketDispatcher pd = EasyMock.createStrictMock(PacketDispatcher.class);
-// CommandManager cm = EasyMock.createStrictMock(CommandManager.class);
-//
-// final int numMessages = 10;
-//
-// final List<ClientMessage> msgs = new ArrayList<ClientMessage>();
-//
-// for (int i = 0; i < numMessages; i++)
-// {
-// ClientMessage msg = EasyMock.createStrictMock(ClientMessage.class);
-//
-// msgs.add(msg);
-//
-// EasyMock.expect(msg.getPriority()).andStubReturn((byte)4); //default priority
-// }
-//
-// EasyMock.replay(session, cm, executor, pd);
-// EasyMock.replay(msgs.toArray());
-//
-// final ClientConsumerInternal consumer =
-// new ClientConsumerImpl(session, 675765, 67565, 787, false, pd, executor, cm);
-//
-// final long pause = 2000;
-//
-// final long timeout = 1000;
-//
-// class AdderThread extends Thread
-// {
-// volatile boolean failed;
-//
-// public void run()
-// {
-// try
-// {
-// Thread.sleep(pause);
-//
-// for (ClientMessage msg: msgs)
-// {
-// consumer.handleMessage(msg);
-// }
-// }
-// catch (Exception e)
-// {
-// log.error("Failed to add messages", e);
-// failed = true;
-// }
-// }
-// };
-//
-// AdderThread t = new AdderThread();
-//
-// t.start();
-//
-// ClientMessage msg = consumer.receive(timeout);
-//
-// assertNull(msg);
-//
-// t.join();
-//
-// assertFalse(t.failed);
-//
-// EasyMock.verify(session, cm, executor, pd);
-// EasyMock.verify(msgs.toArray());
-//
-// assertEquals(numMessages, consumer.getBufferSize());
-// }
-//
-// public void testReceiveExpiredWithTimeout() throws Exception
-// {
-// ClientSessionInternal session = EasyMock.createStrictMock(ClientSessionInternal.class);
-// CommandManager cm = EasyMock.createStrictMock(CommandManager.class);
-// ExecutorService executor = EasyMock.createStrictMock(ExecutorService.class);
-// PacketDispatcher pd = EasyMock.createStrictMock(PacketDispatcher.class);
-//
-// final int numMessages = 10;
-//
-// List<ClientMessage> msgs = new ArrayList<ClientMessage>();
-//
-// for (int i = 0; i < numMessages; i++)
-// {
-// ClientMessage msg = EasyMock.createStrictMock(ClientMessage.class);
-//
-// msgs.add(msg);
-//
-// EasyMock.expect(msg.getPriority()).andStubReturn((byte)4); //default priority
-//
-// EasyMock.expect(msg.isExpired()).andStubReturn(true);
-//
-// EasyMock.expect(msg.getDeliveryID()).andStubReturn((long)i);
-//
-// session.delivered((long)i, true);
-//
-// EasyMock.expect(msg.getEncodeSize()).andReturn(1);
-// }
-//
-// EasyMock.replay(session, cm, executor, pd);
-// EasyMock.replay(msgs.toArray());
-//
-// ClientConsumerInternal consumer =
-// new ClientConsumerImpl(session, 675765, 67565, 787, false, pd, executor, cm);
-//
-// for (ClientMessage msg: msgs)
-// {
-// consumer.handleMessage(msg);
-// }
-//
-// assertEquals(numMessages, consumer.getBufferSize());
-//
-// for (ClientMessage msg: msgs)
-// {
-// assertNull(consumer.receive(100));
-// }
-//
-// EasyMock.verify(session, cm, executor, pd);
-// EasyMock.verify(msgs.toArray());
-// }
-//
-// public void testWaitForOnMessageToCompleteOnClose() throws Exception
-// {
-// ClientSessionInternal session = EasyMock.createStrictMock(ClientSessionInternal.class);
-// ExecutorService executor = Executors.newSingleThreadExecutor();
-// PacketDispatcher pd = EasyMock.createStrictMock(PacketDispatcher.class);
-// CommandManager cm = EasyMock.createStrictMock(CommandManager.class);
-//
-// final long clientTargetID = 283748;
-// final long targetID = 12934;
-//
-// final ClientConsumerInternal consumer =
-// new ClientConsumerImpl(session, targetID, clientTargetID, 787, false, pd, executor, cm);
-//
-// class MyHandler implements MessageHandler
-// {
-// volatile boolean failed;
-// volatile boolean complete;
-// public void onMessage(ClientMessage msg)
-// {
-// try
-// {
-// Thread.sleep(1000);
-// complete = true;
-// }
-// catch (Exception e)
-// {
-// failed = true;
-// }
-// }
-// };
-//
-// MyHandler handler = new MyHandler();
-//
-// consumer.setMessageHandler(handler);
-//
-// ClientMessage msg = EasyMock.createStrictMock(ClientMessage.class);
-//
-// EasyMock.expect(msg.getPriority()).andStubReturn((byte)4); //default priority
-//
-// EasyMock.expect(msg.isExpired()).andStubReturn(false);
-//
-// EasyMock.expect(msg.getDeliveryID()).andStubReturn(0L);
-//
-// session.delivered(0L, false);
-//
-// EasyMock.expect(msg.getEncodeSize()).andReturn(1);
-//
-// pd.unregister(clientTargetID);
-// session.removeConsumer(consumer);
-// EasyMock.expect(cm.sendCommandBlocking(targetID, new PacketImpl(PacketImpl.CLOSE))).andReturn(null);
-// EasyMock.replay(session, cm, pd, msg);
-//
-// consumer.handleMessage(msg);
-//
-// consumer.close();
-//
-// assertTrue(handler.complete);
-//
-// assertFalse(handler.failed);
-//
-// EasyMock.verify(session, cm, pd, msg);
-// }
-//
-// public void testWaitForOnMessageToCompleteOnCloseTimeout() throws Exception
-// {
-// ClientSessionInternal session = EasyMock.createStrictMock(ClientSessionInternal.class);
-// CommandManager cm = EasyMock.createStrictMock(CommandManager.class);
-// ExecutorService executor = Executors.newSingleThreadExecutor();
-// PacketDispatcher pd = EasyMock.createStrictMock(PacketDispatcher.class);
-//
-// final long clientTargetID = 283748;
-// final long targetID = 12934;
-//
-// final ClientConsumerInternal consumer =
-// new ClientConsumerImpl(session, targetID, clientTargetID, 787, false, pd, executor, cm);
-//
-// class MyHandler implements MessageHandler
-// {
-// volatile boolean failed;
-// volatile boolean complete;
-// public void onMessage(ClientMessage msg)
-// {
-// try
-// {
-// Thread.sleep(ClientConsumerImpl.CLOSE_TIMEOUT_MILLISECONDS + 2000);
-// complete = true;
-// }
-// catch (Exception e)
-// {
-// failed = true;
-// }
-// }
-// };
-//
-// MyHandler handler = new MyHandler();
-//
-// consumer.setMessageHandler(handler);
-//
-// ClientMessage msg = EasyMock.createStrictMock(ClientMessage.class);
-//
-// EasyMock.expect(msg.getPriority()).andStubReturn((byte)4); //default priority
-//
-// EasyMock.expect(msg.isExpired()).andStubReturn(false);
-//
-// EasyMock.expect(msg.getDeliveryID()).andStubReturn(0L);
-//
-// session.delivered(0L, false);
-//
-// EasyMock.expect(msg.getEncodeSize()).andReturn(1);
-//
-// pd.unregister(clientTargetID);
-// session.removeConsumer(consumer);
-// EasyMock.expect(cm.sendCommandBlocking(targetID, new PacketImpl(PacketImpl.CLOSE))).andReturn(null);
-// EasyMock.replay(session, cm, pd, msg);
-//
-// consumer.handleMessage(msg);
-//
-// long start = System.currentTimeMillis();
-// consumer.close();
-// long end = System.currentTimeMillis();
-// assertTrue((end - start) >= ClientConsumerImpl.CLOSE_TIMEOUT_MILLISECONDS);
-//
-// assertFalse(handler.complete);
-//
-// assertFalse(handler.failed);
-//
-// EasyMock.verify(session, cm, pd, msg);
-// }
-//
-// public void testWaitForOnMessageToCompleteOnCloseSameThread() throws Exception
-// {
-// ClientSessionInternal session = EasyMock.createStrictMock(ClientSessionInternal.class);
-// ExecutorService executor = new DirectExecutorService();
-// PacketDispatcher pd = EasyMock.createStrictMock(PacketDispatcher.class);
-// CommandManager cm = EasyMock.createStrictMock(CommandManager.class);
-//
-// final long clientTargetID = 283748;
-// final long targetID = 12934;
-//
-// final ClientConsumerInternal consumer =
-// new ClientConsumerImpl(session, targetID, clientTargetID, 787, false, pd, executor, cm);
-//
-// class MyHandler implements MessageHandler
-// {
-// volatile boolean failed;
-// volatile boolean complete;
-// public void onMessage(ClientMessage msg)
-// {
-// try
-// {
-// Thread.sleep(1000);
-// complete = true;
-// }
-// catch (Exception e)
-// {
-// failed = true;
-// }
-// }
-// };
-//
-// MyHandler handler = new MyHandler();
-//
-// consumer.setMessageHandler(handler);
-//
-// ClientMessage msg = EasyMock.createStrictMock(ClientMessage.class);
-//
-// EasyMock.expect(msg.getPriority()).andStubReturn((byte)4); //default priority
-//
-// EasyMock.expect(msg.isExpired()).andStubReturn(false);
-//
-// EasyMock.expect(msg.getDeliveryID()).andStubReturn(0L);
-//
-// session.delivered(0L, false);
-//
-// EasyMock.expect(msg.getEncodeSize()).andReturn(1);
-//
-// pd.unregister(clientTargetID);
-// session.removeConsumer(consumer);
-// EasyMock.expect(cm.sendCommandBlocking(targetID, new PacketImpl(PacketImpl.CLOSE))).andReturn(null);
-// EasyMock.replay(session, cm, pd, msg);
-//
-// consumer.handleMessage(msg);
-//
-// consumer.close();
-//
-// assertTrue(handler.complete);
-//
-// assertFalse(handler.failed);
-//
-// EasyMock.verify(session, cm, pd, msg);
-// }
-
- // Private -----------------------------------------------------------------------------------------------------------
-
-}
More information about the hornetq-commits
mailing list