[hornetq-commits] JBoss hornetq SVN: r8791 - trunk/src/main/org/hornetq/core/remoting/impl/wireformat.

Author: timfox Date: 2010-01-11 13:09:25 -0500 (Mon, 11 Jan 2010) New Revision: 8791 Added: trunk/src/main/org/hornetq/core/remoting/impl/wireformat/SessionCommitMessage.java Log: some packets now processed async + queue has not executor to minimise remoting threads being held for too long, also some other tweaks Added: trunk/src/main/org/hornetq/core/remoting/impl/wireformat/SessionCommitMessage.java =================================================================== --- trunk/src/main/org/hornetq/core/remoting/impl/wireformat/SessionCommitMessage.java (rev 0) +++ trunk/src/main/org/hornetq/core/remoting/impl/wireformat/SessionCommitMessage.java 2010-01-11 18:09:25 UTC (rev 8791) @@ -0,0 +1,57 @@ +/* + * 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.core.remoting.impl.wireformat; + +/** + * A SessionCommitMessage + * + * @author tim + * + * + */ +public class SessionCommitMessage extends PacketImpl +{ + + // Constants ----------------------------------------------------- + + // Attributes ---------------------------------------------------- + + // Static -------------------------------------------------------- + + // Constructors -------------------------------------------------- + + // Public -------------------------------------------------------- + + /** + * @param type + */ + public SessionCommitMessage() + { + super(PacketImpl.SESS_COMMIT); + } + + public boolean isAsyncExec() + { + return true; + } + + // Package protected --------------------------------------------- + + // Protected ----------------------------------------------------- + + // Private ------------------------------------------------------- + + // Inner classes ------------------------------------------------- + +}