You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kw...@apache.org on 2017/02/07 18:38:24 UTC
svn commit: r1782048 [3/12] - in /qpid: java/trunk/ java/trunk/bdbstore/
java/trunk/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/
java/trunk/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuple/
java/trunk/bdbstore/src...
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/ParseException.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/ParseException.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/ParseException.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/ParseException.java Tue Feb 7 18:38:14 2017
@@ -1,27 +1,27 @@
/* Generated By:JavaCC: Do not edit this line. ParseException.java Version 5.0 */
/* JavaCCOptions:KEEP_LINE_COL=null */
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF 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.
- *
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF 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.apache.qpid.filter.selector;
+package org.apache.qpid.server.filter.selector;
/**
* This exception is thrown when parse errors are encountered.
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SelectorParser.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SelectorParser.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SelectorParser.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SelectorParser.java Tue Feb 7 18:38:14 2017
@@ -1,44 +1,44 @@
/* Generated By:JavaCC: Do not edit this line. SelectorParser.java */
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF 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.
- *
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF 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.apache.qpid.filter.selector;
+package org.apache.qpid.server.filter.selector;
import java.io.StringReader;
import java.util.ArrayList;
-import org.apache.qpid.filter.ArithmeticExpression;
-import org.apache.qpid.filter.BooleanExpression;
-import org.apache.qpid.filter.ComparisonExpression;
-import org.apache.qpid.filter.ConstantExpression;
-import org.apache.qpid.filter.Expression;
-import org.apache.qpid.filter.LogicExpression;
-import org.apache.qpid.filter.PropertyExpression;
-import org.apache.qpid.filter.PropertyExpressionFactory;
-import org.apache.qpid.filter.UnaryExpression;
-
-/**
- * JMS Selector Parser generated by JavaCC
- *
- * Do not edit this .java file directly - it is autogenerated from SelectorParser.jj
+import org.apache.qpid.server.filter.ArithmeticExpression;
+import org.apache.qpid.server.filter.BooleanExpression;
+import org.apache.qpid.server.filter.ComparisonExpression;
+import org.apache.qpid.server.filter.ConstantExpression;
+import org.apache.qpid.server.filter.Expression;
+import org.apache.qpid.server.filter.LogicExpression;
+import org.apache.qpid.server.filter.PropertyExpression;
+import org.apache.qpid.server.filter.PropertyExpressionFactory;
+import org.apache.qpid.server.filter.UnaryExpression;
+
+/**
+ * JMS Selector Parser generated by JavaCC
+ *
+ * Do not edit this .java file directly - it is autogenerated from SelectorParser.jj
*/
public class SelectorParser<E> implements SelectorParserConstants {
private PropertyExpressionFactory<E> _factory;
@@ -74,9 +74,9 @@ public class SelectorParser<E> implement
throw new ParseException("Expression will not result in a boolean value: " + value);
}
-// ----------------------------------------------------------------------------
-// Grammer
-// ----------------------------------------------------------------------------
+// ----------------------------------------------------------------------------
+// Grammer
+// ----------------------------------------------------------------------------
final public BooleanExpression JmsSelector() throws ParseException {
Expression left=null;
left = orExpression();
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SelectorParserConstants.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SelectorParserConstants.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SelectorParserConstants.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SelectorParserConstants.java Tue Feb 7 18:38:14 2017
@@ -1,26 +1,26 @@
/* Generated By:JavaCC: Do not edit this line. SelectorParserConstants.java */
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF 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.
- *
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF 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.apache.qpid.filter.selector;
+package org.apache.qpid.server.filter.selector;
/**
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SelectorParserTokenManager.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SelectorParserTokenManager.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SelectorParserTokenManager.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SelectorParserTokenManager.java Tue Feb 7 18:38:14 2017
@@ -20,7 +20,7 @@
*
*/
-package org.apache.qpid.filter.selector;
+package org.apache.qpid.server.filter.selector;
/** Token Manager. */
public class SelectorParserTokenManager implements SelectorParserConstants
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SimpleCharStream.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SimpleCharStream.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SimpleCharStream.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/SimpleCharStream.java Tue Feb 7 18:38:14 2017
@@ -1,27 +1,27 @@
/* Generated By:JavaCC: Do not edit this line. SimpleCharStream.java Version 5.0 */
/* JavaCCOptions:STATIC=false,SUPPORT_CLASS_VISIBILITY_PUBLIC=true */
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF 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.
- *
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF 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.apache.qpid.filter.selector;
+package org.apache.qpid.server.filter.selector;
/**
* An implementation of interface CharStream, where the stream is assumed to
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/Token.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/Token.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/Token.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/Token.java Tue Feb 7 18:38:14 2017
@@ -1,27 +1,27 @@
/* Generated By:JavaCC: Do not edit this line. Token.java Version 5.0 */
/* JavaCCOptions:TOKEN_EXTENDS=,KEEP_LINE_COL=null,SUPPORT_CLASS_VISIBILITY_PUBLIC=true */
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF 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.
- *
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF 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.apache.qpid.filter.selector;
+package org.apache.qpid.server.filter.selector;
/**
* Describes the input token stream.
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/TokenMgrError.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/TokenMgrError.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/TokenMgrError.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/filter/selector/TokenMgrError.java Tue Feb 7 18:38:14 2017
@@ -1,27 +1,27 @@
/* Generated By:JavaCC: Do not edit this line. TokenMgrError.java Version 5.0 */
/* JavaCCOptions: */
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF 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.
- *
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF 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.apache.qpid.filter.selector;
+package org.apache.qpid.server.filter.selector;
/** Token Manager Error. */
public class TokenMgrError extends Error
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQBody.java Tue Feb 7 18:38:14 2017
@@ -18,11 +18,11 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.protocol.AMQVersionAwareProtocolSession;
-import org.apache.qpid.transport.ByteBufferSender;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.protocol.AMQVersionAwareProtocolSession;
+import org.apache.qpid.server.transport.ByteBufferSender;
public interface AMQBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQDataBlock.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQDataBlock.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQDataBlock.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQDataBlock.java Tue Feb 7 18:38:14 2017
@@ -18,9 +18,9 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.transport.ByteBufferSender;
+import org.apache.qpid.server.transport.ByteBufferSender;
/**
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQFrame.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQFrame.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQFrame.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQFrame.java Tue Feb 7 18:38:14 2017
@@ -18,10 +18,10 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
-import org.apache.qpid.transport.ByteBufferSender;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.transport.ByteBufferSender;
public class AMQFrame extends AMQDataBlock implements EncodableAMQDataBlock
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQFrameDecodingException.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQFrameDecodingException.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQFrameDecodingException.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQFrameDecodingException.java Tue Feb 7 18:38:14 2017
@@ -18,10 +18,10 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.AMQException;
-import org.apache.qpid.protocol.ErrorCodes;
+import org.apache.qpid.server.AMQException;
+import org.apache.qpid.server.protocol.ErrorCodes;
/**
* AMQFrameDecodingException indicates that an AMQP frame cannot be decoded because it does not have the correct
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQMethodBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQMethodBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQMethodBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQMethodBody.java Tue Feb 7 18:38:14 2017
@@ -18,9 +18,9 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
+import org.apache.qpid.server.QpidException;
public interface AMQMethodBody extends AMQBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQMethodBodyImpl.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQMethodBodyImpl.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQMethodBodyImpl.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQMethodBodyImpl.java Tue Feb 7 18:38:14 2017
@@ -18,15 +18,15 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
-import org.apache.qpid.protocol.AMQVersionAwareProtocolSession;
-import org.apache.qpid.transport.ByteBufferSender;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.protocol.AMQVersionAwareProtocolSession;
+import org.apache.qpid.server.transport.ByteBufferSender;
public abstract class AMQMethodBodyImpl implements AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolClassException.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolClassException.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolClassException.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolClassException.java Tue Feb 7 18:38:14 2017
@@ -18,7 +18,7 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
/**
* AMQProtocolInstanceException indicates that the protocol class is incorrect in a header.
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolHeaderException.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolHeaderException.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolHeaderException.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolHeaderException.java Tue Feb 7 18:38:14 2017
@@ -18,9 +18,9 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.transport.TransportException;
+import org.apache.qpid.server.transport.TransportException;
public class AMQProtocolHeaderException extends TransportException
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolInstanceException.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolInstanceException.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolInstanceException.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolInstanceException.java Tue Feb 7 18:38:14 2017
@@ -18,7 +18,7 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
/**
* AMQProtocolInstanceException indicates that the protocol instance is incorrect in a header.
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolVersionException.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolVersionException.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolVersionException.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQProtocolVersionException.java Tue Feb 7 18:38:14 2017
@@ -18,7 +18,7 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
/**
* AMQProtocolInstanceException indicates that the client and server differ on expected protocol version in a header.
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQShortString.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQShortString.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQShortString.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQShortString.java Tue Feb 7 18:38:14 2017
@@ -19,7 +19,7 @@
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
import java.nio.ByteBuffer;
import java.nio.charset.StandardCharsets;
@@ -28,7 +28,7 @@ import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
/**
* A short string is a representation of an AMQ Short String
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQType.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQType.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQType.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQType.java Tue Feb 7 18:38:14 2017
@@ -18,12 +18,12 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
import java.math.BigDecimal;
import java.util.Collection;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
/**
* AMQType is a type that represents the different possible AMQP field table types. It provides operations for each
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQTypeMap.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQTypeMap.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQTypeMap.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQTypeMap.java Tue Feb 7 18:38:14 2017
@@ -18,7 +18,7 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
import java.util.HashMap;
import java.util.Map;
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQTypedValue.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQTypedValue.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQTypedValue.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AMQTypedValue.java Tue Feb 7 18:38:14 2017
@@ -18,14 +18,14 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
import java.math.BigDecimal;
import java.util.Collection;
import java.util.Date;
import java.util.Map;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
/**
* AMQTypedValue combines together a native Java Object value, and an {@link AMQType}, as a fully typed AMQP parameter
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AccessRequestBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AccessRequestBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AccessRequestBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AccessRequestBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class AccessRequestBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AccessRequestOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AccessRequestOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AccessRequestOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/AccessRequestOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class AccessRequestOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicAckBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicAckBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicAckBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicAckBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicAckBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicCancelBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicCancelBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicCancelBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicCancelBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicCancelBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicCancelOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicCancelOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicCancelOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicCancelOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicCancelOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicConsumeBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicConsumeBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicConsumeBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicConsumeBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicConsumeBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicConsumeOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicConsumeOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicConsumeOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicConsumeOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicConsumeOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicContentHeaderProperties.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicContentHeaderProperties.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicContentHeaderProperties.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicContentHeaderProperties.java Tue Feb 7 18:38:14 2017
@@ -18,13 +18,13 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
-import org.apache.qpid.transport.ByteBufferSender;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.transport.ByteBufferSender;
public class BasicContentHeaderProperties
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicDeliverBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicDeliverBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicDeliverBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicDeliverBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicDeliverBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicGetBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicGetBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicGetBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicGetBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicGetBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicGetEmptyBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicGetEmptyBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicGetEmptyBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicGetEmptyBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicGetEmptyBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicGetOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicGetOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicGetOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicGetOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicGetOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicNackBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicNackBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicNackBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicNackBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicNackBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicPublishBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicPublishBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicPublishBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicPublishBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicPublishBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicQosBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicQosBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicQosBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicQosBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicQosBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicQosOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicQosOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicQosOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicQosOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicQosOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRecoverBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRecoverBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRecoverBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRecoverBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicRecoverBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRecoverSyncBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRecoverSyncBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRecoverSyncBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRecoverSyncBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 0-91
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicRecoverSyncBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRecoverSyncOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRecoverSyncOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRecoverSyncOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRecoverSyncOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 0-91
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicRecoverSyncOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRejectBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRejectBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRejectBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicRejectBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicRejectBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicReturnBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicReturnBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicReturnBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/BasicReturnBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class BasicReturnBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelAlertBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelAlertBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelAlertBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelAlertBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ChannelAlertBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelCloseBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelCloseBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelCloseBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelCloseBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ChannelCloseBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelCloseOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelCloseOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelCloseOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelCloseOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ChannelCloseOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelFlowBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelFlowBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelFlowBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelFlowBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ChannelFlowBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelFlowOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelFlowOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelFlowOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelFlowOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ChannelFlowOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelMethodProcessor.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelMethodProcessor.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelMethodProcessor.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelMethodProcessor.java Tue Feb 7 18:38:14 2017
@@ -18,9 +18,9 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public interface ChannelMethodProcessor
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelOpenBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelOpenBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelOpenBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelOpenBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ChannelOpenBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelOpenOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelOpenOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelOpenOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ChannelOpenOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,12 +25,12 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
import java.io.IOException;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ChannelOpenOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ClientChannelMethodProcessor.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ClientChannelMethodProcessor.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ClientChannelMethodProcessor.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ClientChannelMethodProcessor.java Tue Feb 7 18:38:14 2017
@@ -18,7 +18,7 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
public interface ClientChannelMethodProcessor extends ChannelMethodProcessor
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ClientMethodDispatcher.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ClientMethodDispatcher.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ClientMethodDispatcher.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ClientMethodDispatcher.java Tue Feb 7 18:38:14 2017
@@ -27,9 +27,9 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
+import org.apache.qpid.server.QpidException;
public interface ClientMethodDispatcher
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ClientMethodProcessor.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ClientMethodProcessor.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ClientMethodProcessor.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ClientMethodProcessor.java Tue Feb 7 18:38:14 2017
@@ -18,7 +18,7 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
public interface ClientMethodProcessor<T extends ClientChannelMethodProcessor> extends MethodProcessor<T>
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/CompositeAMQDataBlock.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/CompositeAMQDataBlock.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/CompositeAMQDataBlock.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/CompositeAMQDataBlock.java Tue Feb 7 18:38:14 2017
@@ -18,9 +18,9 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.transport.ByteBufferSender;
+import org.apache.qpid.server.transport.ByteBufferSender;
public class CompositeAMQDataBlock extends AMQDataBlock implements EncodableAMQDataBlock
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConfirmSelectBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConfirmSelectBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConfirmSelectBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConfirmSelectBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConfirmSelectBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConfirmSelectOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConfirmSelectOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConfirmSelectOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConfirmSelectOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConfirmSelectOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionCloseBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionCloseBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionCloseBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionCloseBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 0-91
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConnectionCloseBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionCloseOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionCloseOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionCloseOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionCloseOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 0-91
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConnectionCloseOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionOpenBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionOpenBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionOpenBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionOpenBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConnectionOpenBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionOpenOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionOpenOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionOpenOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionOpenOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConnectionOpenOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionRedirectBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionRedirectBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionRedirectBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionRedirectBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConnectionRedirectBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionSecureBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionSecureBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionSecureBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionSecureBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConnectionSecureBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionSecureOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionSecureOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionSecureOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionSecureOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConnectionSecureOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionStartBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionStartBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionStartBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionStartBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConnectionStartBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionStartOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionStartOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionStartOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionStartOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConnectionStartOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionTuneBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionTuneBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionTuneBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionTuneBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConnectionTuneBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionTuneOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionTuneOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionTuneOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ConnectionTuneOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ConnectionTuneOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ContentBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ContentBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ContentBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ContentBody.java Tue Feb 7 18:38:14 2017
@@ -18,14 +18,14 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
import java.nio.ByteBuffer;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
-import org.apache.qpid.protocol.AMQVersionAwareProtocolSession;
-import org.apache.qpid.transport.ByteBufferSender;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.protocol.AMQVersionAwareProtocolSession;
+import org.apache.qpid.server.transport.ByteBufferSender;
public class ContentBody implements AMQBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ContentHeaderBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ContentHeaderBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ContentHeaderBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ContentHeaderBody.java Tue Feb 7 18:38:14 2017
@@ -18,12 +18,12 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
-import org.apache.qpid.protocol.AMQVersionAwareProtocolSession;
-import org.apache.qpid.transport.ByteBufferSender;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.protocol.AMQVersionAwareProtocolSession;
+import org.apache.qpid.server.transport.ByteBufferSender;
public class ContentHeaderBody implements AMQBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ContentHeaderPropertiesFactory.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ContentHeaderPropertiesFactory.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ContentHeaderPropertiesFactory.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ContentHeaderPropertiesFactory.java Tue Feb 7 18:38:14 2017
@@ -18,9 +18,9 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ContentHeaderPropertiesFactory
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/EncodableAMQDataBlock.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/EncodableAMQDataBlock.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/EncodableAMQDataBlock.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/EncodableAMQDataBlock.java Tue Feb 7 18:38:14 2017
@@ -18,7 +18,7 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
/**
* Marker interface to indicate to MINA that a data block should be encoded with the
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/EncodingUtils.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/EncodingUtils.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/EncodingUtils.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/EncodingUtils.java Tue Feb 7 18:38:14 2017
@@ -18,14 +18,14 @@
* under the License.
*
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
import java.nio.charset.StandardCharsets;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class EncodingUtils
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeBoundBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeBoundBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeBoundBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeBoundBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ExchangeBoundBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeBoundOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeBoundOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeBoundOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeBoundOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ExchangeBoundOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeclareBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeclareBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeclareBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeclareBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ExchangeDeclareBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeclareOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeclareOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeclareOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeclareOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ExchangeDeclareOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeleteBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeleteBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeleteBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeleteBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ExchangeDeleteBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeleteOkBody.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeleteOkBody.java?rev=1782048&r1=1781779&r2=1782048&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeleteOkBody.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/framing/ExchangeDeleteOkBody.java Tue Feb 7 18:38:14 2017
@@ -25,10 +25,10 @@
* 8-0
*/
-package org.apache.qpid.framing;
+package org.apache.qpid.server.framing;
-import org.apache.qpid.QpidException;
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import org.apache.qpid.server.QpidException;
+import org.apache.qpid.server.bytebuffer.QpidByteBuffer;
public class ExchangeDeleteOkBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody
{
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org