[jboss-cvs] JBoss Messaging SVN: r4154 - in trunk: src/main/org/jboss/messaging/core/client/impl and 4 other directories.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Tue May 6 16:02:51 EDT 2008
Author: timfox
Date: 2008-05-06 16:02:50 -0400 (Tue, 06 May 2008)
New Revision: 4154
Removed:
trunk/src/main/org/jboss/messaging/core/remoting/impl/codec/SessionBrowserNextMessageBlockMessageCodec.java
trunk/src/main/org/jboss/messaging/core/remoting/impl/codec/SessionBrowserNextMessageBlockResponseMessageCodec.java
trunk/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionBrowserNextMessageBlockMessage.java
trunk/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionBrowserNextMessageBlockResponseMessage.java
Modified:
trunk/src/main/org/jboss/messaging/core/client/ClientBrowser.java
trunk/src/main/org/jboss/messaging/core/client/impl/ClientBrowserImpl.java
trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/FilterChainSupport.java
trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/PacketCodecFactory.java
trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/wireformat/PacketTypeTest.java
Log:
Removed browser message block
Modified: trunk/src/main/org/jboss/messaging/core/client/ClientBrowser.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/ClientBrowser.java 2008-05-06 18:51:11 UTC (rev 4153)
+++ trunk/src/main/org/jboss/messaging/core/client/ClientBrowser.java 2008-05-06 20:02:50 UTC (rev 4154)
@@ -23,8 +23,6 @@
boolean hasNextMessage() throws MessagingException;
- Message[] nextMessageBlock(int maxMessages) throws MessagingException;
-
void close() throws MessagingException;
boolean isClosed();
Modified: trunk/src/main/org/jboss/messaging/core/client/impl/ClientBrowserImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/ClientBrowserImpl.java 2008-05-06 18:51:11 UTC (rev 4153)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/ClientBrowserImpl.java 2008-05-06 20:02:50 UTC (rev 4154)
@@ -31,8 +31,6 @@
import org.jboss.messaging.core.message.Message;
import org.jboss.messaging.core.remoting.impl.wireformat.PacketImpl;
import org.jboss.messaging.core.remoting.impl.wireformat.SessionBrowserHasNextMessageResponseMessage;
-import org.jboss.messaging.core.remoting.impl.wireformat.SessionBrowserNextMessageBlockMessage;
-import org.jboss.messaging.core.remoting.impl.wireformat.SessionBrowserNextMessageBlockResponseMessage;
import org.jboss.messaging.core.remoting.impl.wireformat.SessionBrowserNextMessageResponseMessage;
/**
@@ -125,15 +123,6 @@
return response.getMessage();
}
- public Message[] nextMessageBlock(final int maxMessages) throws MessagingException
- {
- checkClosed();
-
- SessionBrowserNextMessageBlockResponseMessage response =
- (SessionBrowserNextMessageBlockResponseMessage)remotingConnection.sendBlocking(serverTargetID, session.getServerTargetID(), new SessionBrowserNextMessageBlockMessage(maxMessages));
- return response.getMessages();
- }
-
// Public ---------------------------------------------------------------------------------------
// Protected ------------------------------------------------------------------------------------
Deleted: trunk/src/main/org/jboss/messaging/core/remoting/impl/codec/SessionBrowserNextMessageBlockMessageCodec.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/codec/SessionBrowserNextMessageBlockMessageCodec.java 2008-05-06 18:51:11 UTC (rev 4153)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/codec/SessionBrowserNextMessageBlockMessageCodec.java 2008-05-06 20:02:50 UTC (rev 4154)
@@ -1,65 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- *
- * Distributable under LGPL license.
- * See terms of license at gnu.org.
- */
-package org.jboss.messaging.core.remoting.impl.codec;
-
-import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_NEXTMESSAGEBLOCK;
-import static org.jboss.messaging.util.DataConstants.SIZE_LONG;
-
-import org.jboss.messaging.core.remoting.impl.wireformat.SessionBrowserNextMessageBlockMessage;
-import org.jboss.messaging.util.DataConstants;
-
-/**
- * @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
- * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
- */
-public class SessionBrowserNextMessageBlockMessageCodec extends AbstractPacketCodec<SessionBrowserNextMessageBlockMessage>
-{
- // Constants -----------------------------------------------------
-
- // Attributes ----------------------------------------------------
-
- // Static --------------------------------------------------------
-
- // Constructors --------------------------------------------------
-
- public SessionBrowserNextMessageBlockMessageCodec()
- {
- super(SESS_BROWSER_NEXTMESSAGEBLOCK);
- }
-
- // Public --------------------------------------------------------
-
- // AbstractPacketCodec overrides ---------------------------------
-
- public int getBodyLength(final SessionBrowserNextMessageBlockMessage packet) throws Exception
- {
- return SIZE_LONG;
- }
-
- @Override
- protected void encodeBody(final SessionBrowserNextMessageBlockMessage request, final RemotingBuffer out) throws Exception
- {
- out.putLong(request.getMaxMessages());
- }
-
- @Override
- protected SessionBrowserNextMessageBlockMessage decodeBody(final RemotingBuffer in)
- throws Exception
- {
- long maxMessages = in.getLong();
-
- return new SessionBrowserNextMessageBlockMessage(maxMessages);
- }
-
- // Package protected ---------------------------------------------
-
- // Protected -----------------------------------------------------
-
- // Private ----------------------------------------------------
-
- // Inner classes -------------------------------------------------
-}
Deleted: trunk/src/main/org/jboss/messaging/core/remoting/impl/codec/SessionBrowserNextMessageBlockResponseMessageCodec.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/codec/SessionBrowserNextMessageBlockResponseMessageCodec.java 2008-05-06 18:51:11 UTC (rev 4153)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/codec/SessionBrowserNextMessageBlockResponseMessageCodec.java 2008-05-06 20:02:50 UTC (rev 4154)
@@ -1,120 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- *
- * Distributable under LGPL license.
- * See terms of license at gnu.org.
- */
-package org.jboss.messaging.core.remoting.impl.codec;
-
-import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_NEXTMESSAGEBLOCK_RESP;
-import static org.jboss.messaging.util.DataConstants.SIZE_INT;
-
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.DataInputStream;
-import java.io.DataOutputStream;
-
-import org.jboss.messaging.core.message.Message;
-import org.jboss.messaging.core.message.impl.MessageImpl;
-import org.jboss.messaging.core.remoting.impl.wireformat.SessionBrowserNextMessageBlockResponseMessage;
-import org.jboss.messaging.util.DataConstants;
-
-/**
- * @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
- * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
- */
-public class SessionBrowserNextMessageBlockResponseMessageCodec extends AbstractPacketCodec<SessionBrowserNextMessageBlockResponseMessage>
-{
- // Constants -----------------------------------------------------
-
- // Attributes ----------------------------------------------------
-
- // Static --------------------------------------------------------
-
- public static byte[] encode(final Message[] messages) throws Exception
- {
- ByteArrayOutputStream baos = new ByteArrayOutputStream();
- DataOutputStream daos = new DataOutputStream(baos);
-
- daos.writeInt(messages.length);
-
- for (int i = 0; i < messages.length; i++)
- {
- Message message = messages[i];
- message.write(daos);
- }
- return baos.toByteArray();
- }
-
- // Constructors --------------------------------------------------
-
- public SessionBrowserNextMessageBlockResponseMessageCodec()
- {
- super(SESS_BROWSER_NEXTMESSAGEBLOCK_RESP);
- }
-
- // Public --------------------------------------------------------
-
- // AbstractPacketCodec overrides ---------------------------------
-
- //TODO remove this in next refactoring
- private byte[] encodedMsgs;
-
- public int getBodyLength(final SessionBrowserNextMessageBlockResponseMessage packet) throws Exception
- {
- Message[] messages = packet.getMessages();
-
- encodedMsgs = encode(messages);
-
- int bodyLength = SIZE_INT + encodedMsgs.length;
-
- return bodyLength;
- }
-
- @Override
- protected void encodeBody(SessionBrowserNextMessageBlockResponseMessage response, RemotingBuffer out) throws Exception
- {
- out.putInt(encodedMsgs.length);
- out.put(encodedMsgs);
- encodedMsgs = null;
- }
-
- @Override
- protected SessionBrowserNextMessageBlockResponseMessage decodeBody(final RemotingBuffer in)
- throws Exception
- {
- int encodedMessagesLength = in.getInt();
- byte[] encodedMessages = new byte[encodedMessagesLength];
- in.get(encodedMessages);
- Message[] messages = decode(encodedMessages);
-
- return new SessionBrowserNextMessageBlockResponseMessage(messages);
- }
-
- // Package protected ---------------------------------------------
-
- // Protected -----------------------------------------------------
-
- // Private ----------------------------------------------------
-
- private Message[] decode(final byte[] encodedMessages) throws Exception
- {
-
- ByteArrayInputStream bais = new ByteArrayInputStream(encodedMessages);
- DataInputStream dais = new DataInputStream(bais);
-
- int numOfMessages = dais.readInt();
- Message[] messages = new Message[numOfMessages];
-
- for (int i = 0; i < messages.length; i++)
- {
- Message message = new MessageImpl();
- message.read(dais);
- messages[i] = message;
- }
-
- return messages;
- }
-
- // Inner classes -------------------------------------------------
-}
Modified: trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/FilterChainSupport.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/FilterChainSupport.java 2008-05-06 18:51:11 UTC (rev 4153)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/FilterChainSupport.java 2008-05-06 20:02:50 UTC (rev 4154)
@@ -97,32 +97,32 @@
// Package protected ---------------------------------------------
- static void addMDCFilter(final DefaultIoFilterChainBuilder filterChain)
- {
- assert filterChain != null;
+// static void addMDCFilter(final DefaultIoFilterChainBuilder filterChain)
+// {
+// assert filterChain != null;
+//
+// MdcInjectionFilter mdcInjectionFilter = new MdcInjectionFilter();
+// filterChain.addLast("mdc", mdcInjectionFilter);
+// }
+//
+// static void addLoggingFilter(final DefaultIoFilterChainBuilder filterChain)
+// {
+// assert filterChain != null;
+//
+// LoggingFilter filter = new LoggingFilter();
+//
+// filter.setSessionCreatedLogLevel(TRACE);
+// filter.setSessionOpenedLogLevel(TRACE);
+// filter.setSessionIdleLogLevel(TRACE);
+// filter.setSessionClosedLogLevel(TRACE);
+//
+// filter.setMessageReceivedLogLevel(TRACE);
+// filter.setMessageSentLogLevel(TRACE);
+//
+// filter.setExceptionCaughtLogLevel(WARN);
+//
+// filterChain.addLast("logger", filter);
+// }
- MdcInjectionFilter mdcInjectionFilter = new MdcInjectionFilter();
- filterChain.addLast("mdc", mdcInjectionFilter);
- }
-
- static void addLoggingFilter(final DefaultIoFilterChainBuilder filterChain)
- {
- assert filterChain != null;
-
- LoggingFilter filter = new LoggingFilter();
-
- filter.setSessionCreatedLogLevel(TRACE);
- filter.setSessionOpenedLogLevel(TRACE);
- filter.setSessionIdleLogLevel(TRACE);
- filter.setSessionClosedLogLevel(TRACE);
-
- filter.setMessageReceivedLogLevel(TRACE);
- filter.setMessageSentLogLevel(TRACE);
-
- filter.setExceptionCaughtLogLevel(WARN);
-
- filterChain.addLast("logger", filter);
- }
-
// Inner classes -------------------------------------------------
}
Modified: trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/PacketCodecFactory.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/PacketCodecFactory.java 2008-05-06 18:51:11 UTC (rev 4153)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/mina/PacketCodecFactory.java 2008-05-06 20:02:50 UTC (rev 4154)
@@ -29,8 +29,6 @@
import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_HASNEXTMESSAGE;
import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_HASNEXTMESSAGE_RESP;
import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_NEXTMESSAGE;
-import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_NEXTMESSAGEBLOCK;
-import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_NEXTMESSAGEBLOCK_RESP;
import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_NEXTMESSAGE_RESP;
import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_RESET;
import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_CANCEL;
@@ -91,8 +89,6 @@
import org.jboss.messaging.core.remoting.impl.codec.SessionBindingQueryMessageCodec;
import org.jboss.messaging.core.remoting.impl.codec.SessionBindingQueryResponseMessageCodec;
import org.jboss.messaging.core.remoting.impl.codec.SessionBrowserHasNextMessageResponseMessageCodec;
-import org.jboss.messaging.core.remoting.impl.codec.SessionBrowserNextMessageBlockMessageCodec;
-import org.jboss.messaging.core.remoting.impl.codec.SessionBrowserNextMessageBlockResponseMessageCodec;
import org.jboss.messaging.core.remoting.impl.codec.SessionBrowserNextMessageResponseMessageCodec;
import org.jboss.messaging.core.remoting.impl.codec.SessionCancelMessageCodec;
import org.jboss.messaging.core.remoting.impl.codec.SessionCreateBrowserMessageCodec;
@@ -208,10 +204,6 @@
addCodec(SESS_BROWSER_NEXTMESSAGE_RESP, new SessionBrowserNextMessageResponseMessageCodec());
- addCodec(SESS_BROWSER_NEXTMESSAGEBLOCK, new SessionBrowserNextMessageBlockMessageCodec());
-
- addCodec(SESS_BROWSER_NEXTMESSAGEBLOCK_RESP, new SessionBrowserNextMessageBlockResponseMessageCodec());
-
addCodec(SESS_XA_COMMIT, new SessionXACommitMessageCodec());
addCodec(SESS_XA_END, new SessionXAEndMessageCodec());
Deleted: trunk/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionBrowserNextMessageBlockMessage.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionBrowserNextMessageBlockMessage.java 2008-05-06 18:51:11 UTC (rev 4153)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionBrowserNextMessageBlockMessage.java 2008-05-06 20:02:50 UTC (rev 4154)
@@ -1,57 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- *
- * Distributable under LGPL license.
- * See terms of license at gnu.org.
- */
-package org.jboss.messaging.core.remoting.impl.wireformat;
-
-import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_NEXTMESSAGEBLOCK;
-
-/**
- * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
- * @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
- *
- * @version <tt>$Revision$</tt>
- *
- */
-public class SessionBrowserNextMessageBlockMessage extends PacketImpl
-{
- // Constants -----------------------------------------------------
-
- // Attributes ----------------------------------------------------
-
- private final long maxMessages;
-
- // Static --------------------------------------------------------
-
- // Constructors --------------------------------------------------
-
- public SessionBrowserNextMessageBlockMessage(final long maxMessages)
- {
- super(SESS_BROWSER_NEXTMESSAGEBLOCK);
-
- this.maxMessages = maxMessages;
- }
-
- // Public --------------------------------------------------------
-
- public long getMaxMessages()
- {
- return maxMessages;
- }
-
- @Override
- public String toString()
- {
- return getParentString() + ", maxMessages=" + maxMessages + "]";
- }
-
- // Package protected ---------------------------------------------
-
- // Protected -----------------------------------------------------
-
- // Private -------------------------------------------------------
-
- // Inner classes -------------------------------------------------
-}
Deleted: trunk/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionBrowserNextMessageBlockResponseMessage.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionBrowserNextMessageBlockResponseMessage.java 2008-05-06 18:51:11 UTC (rev 4153)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionBrowserNextMessageBlockResponseMessage.java 2008-05-06 20:02:50 UTC (rev 4154)
@@ -1,62 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- *
- * Distributable under LGPL license.
- * See terms of license at gnu.org.
- */
-package org.jboss.messaging.core.remoting.impl.wireformat;
-
-import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_NEXTMESSAGEBLOCK_RESP;
-
-import java.util.Arrays;
-
-import org.jboss.messaging.core.message.Message;
-
-/**
- * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
- * @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
- *
- * @version <tt>$Revision$</tt>
- */
-public class SessionBrowserNextMessageBlockResponseMessage extends PacketImpl
-{
- // Constants -----------------------------------------------------
-
- // Attributes ----------------------------------------------------
-
- private final Message[] messages;
-
- // Static --------------------------------------------------------
-
- // Constructors --------------------------------------------------
-
- public SessionBrowserNextMessageBlockResponseMessage(final Message[] messages)
- {
- super(SESS_BROWSER_NEXTMESSAGEBLOCK_RESP);
-
- assert messages != null;
-
- this.messages = messages;
- }
-
- // Public --------------------------------------------------------
-
- public Message[] getMessages()
- {
- return messages;
- }
-
- @Override
- public String toString()
- {
- return getParentString() + ", messages=" + Arrays.asList(messages) + "]";
- }
-
- // Package protected ---------------------------------------------
-
- // Protected -----------------------------------------------------
-
- // Private -------------------------------------------------------
-
- // Inner classes -------------------------------------------------
-}
Modified: trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/wireformat/PacketTypeTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/wireformat/PacketTypeTest.java 2008-05-06 18:51:11 UTC (rev 4153)
+++ trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/wireformat/PacketTypeTest.java 2008-05-06 20:02:50 UTC (rev 4154)
@@ -27,8 +27,6 @@
import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_HASNEXTMESSAGE;
import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_HASNEXTMESSAGE_RESP;
import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_NEXTMESSAGE;
-import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_NEXTMESSAGEBLOCK;
-import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_NEXTMESSAGEBLOCK_RESP;
import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_NEXTMESSAGE_RESP;
import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_BROWSER_RESET;
import static org.jboss.messaging.core.remoting.impl.wireformat.PacketType.SESS_CANCEL;
@@ -105,8 +103,6 @@
import org.jboss.messaging.core.remoting.impl.codec.SessionBindingQueryMessageCodec;
import org.jboss.messaging.core.remoting.impl.codec.SessionBindingQueryResponseMessageCodec;
import org.jboss.messaging.core.remoting.impl.codec.SessionBrowserHasNextMessageResponseMessageCodec;
-import org.jboss.messaging.core.remoting.impl.codec.SessionBrowserNextMessageBlockMessageCodec;
-import org.jboss.messaging.core.remoting.impl.codec.SessionBrowserNextMessageBlockResponseMessageCodec;
import org.jboss.messaging.core.remoting.impl.codec.SessionBrowserNextMessageResponseMessageCodec;
import org.jboss.messaging.core.remoting.impl.codec.SessionCancelMessageCodec;
import org.jboss.messaging.core.remoting.impl.codec.SessionCreateBrowserMessageCodec;
@@ -154,8 +150,6 @@
import org.jboss.messaging.core.remoting.impl.wireformat.SessionBindingQueryMessage;
import org.jboss.messaging.core.remoting.impl.wireformat.SessionBindingQueryResponseMessage;
import org.jboss.messaging.core.remoting.impl.wireformat.SessionBrowserHasNextMessageResponseMessage;
-import org.jboss.messaging.core.remoting.impl.wireformat.SessionBrowserNextMessageBlockMessage;
-import org.jboss.messaging.core.remoting.impl.wireformat.SessionBrowserNextMessageBlockResponseMessage;
import org.jboss.messaging.core.remoting.impl.wireformat.SessionBrowserNextMessageResponseMessage;
import org.jboss.messaging.core.remoting.impl.wireformat.SessionCancelMessage;
import org.jboss.messaging.core.remoting.impl.wireformat.SessionCreateBrowserMessage;
@@ -874,42 +868,6 @@
.getMessage().getMessageID());
}
- public void testSessionBrowserNextMessageBlockMessage() throws Exception
- {
- SessionBrowserNextMessageBlockMessage request = new SessionBrowserNextMessageBlockMessage(
- randomLong());
- AbstractPacketCodec codec = new SessionBrowserNextMessageBlockMessageCodec();
-
- Packet decodedPacket = encodeAndCheckBytesAndDecode(request, codec,
- request.getMaxMessages());
-
- assertTrue(decodedPacket instanceof SessionBrowserNextMessageBlockMessage);
- SessionBrowserNextMessageBlockMessage decodedRequest = (SessionBrowserNextMessageBlockMessage) decodedPacket;
- assertEquals(SESS_BROWSER_NEXTMESSAGEBLOCK, decodedPacket.getType());
- assertEquals(request.getMaxMessages(), decodedRequest.getMaxMessages());
- }
-
- public void testSessionBrowserNextMessageBlockResponseMessage()
- throws Exception
- {
- Message[] messages = new Message[] { new MessageImpl(), new MessageImpl() };
- SessionBrowserNextMessageBlockResponseMessage response = new SessionBrowserNextMessageBlockResponseMessage(
- messages);
- AbstractPacketCodec codec = new SessionBrowserNextMessageBlockResponseMessageCodec();
-
- Packet decodedPacket = encodeAndCheckBytesAndDecode(response, codec,
- SessionBrowserNextMessageBlockResponseMessageCodec.encode(messages));
-
- assertTrue(decodedPacket instanceof SessionBrowserNextMessageBlockResponseMessage);
- SessionBrowserNextMessageBlockResponseMessage decodedResponse = (SessionBrowserNextMessageBlockResponseMessage) decodedPacket;
- assertEquals(SESS_BROWSER_NEXTMESSAGEBLOCK_RESP, decodedResponse
- .getType());
- assertEquals(response.getMessages()[0].getMessageID(), decodedResponse
- .getMessages()[0].getMessageID());
- assertEquals(response.getMessages()[1].getMessageID(), decodedResponse
- .getMessages()[1].getMessageID());
- }
-
public void testSessionXACommitMessage() throws Exception
{
SessionXACommitMessage message = new SessionXACommitMessage(randomXid(),
More information about the jboss-cvs-commits
mailing list