http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Terminus.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Terminus.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Terminus.java deleted file mode 100644 index 844dfa4..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/Terminus.java +++ /dev/null @@ -1,129 +0,0 @@ -/* - * - * 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.proton.amqp.messaging; - -import java.util.HashMap; -import java.util.Map; - -import org.apache.qpid.proton.amqp.Symbol; -import org.apache.qpid.proton.amqp.UnsignedInteger; - -public abstract class Terminus -{ - private String _address; - private TerminusDurability _durable = TerminusDurability.NONE; - private TerminusExpiryPolicy _expiryPolicy = TerminusExpiryPolicy.SESSION_END; - private UnsignedInteger _timeout = UnsignedInteger.valueOf(0); - private boolean _dynamic; - private Map _dynamicNodeProperties; - private Symbol[] _capabilities; - - Terminus() - { - } - - protected Terminus(Terminus other) { - _address = other._address; - _durable = other._durable; - _expiryPolicy = other._expiryPolicy; - _timeout = other._timeout; - _dynamic = other._dynamic; - if (other._dynamicNodeProperties != null) { - // TODO: Do we need to copy or can we make a simple reference? - _dynamicNodeProperties = new HashMap(other._dynamicNodeProperties); - } - if (other._capabilities != null) { - _capabilities = other._capabilities.clone(); - } - } - - public final String getAddress() - { - return _address; - } - - public final void setAddress(String address) - { - _address = address; - } - - public final TerminusDurability getDurable() - { - return _durable; - } - - public final void setDurable(TerminusDurability durable) - { - _durable = durable == null ? TerminusDurability.NONE : durable; - } - - public final TerminusExpiryPolicy getExpiryPolicy() - { - return _expiryPolicy; - } - - public final void setExpiryPolicy(TerminusExpiryPolicy expiryPolicy) - { - _expiryPolicy = expiryPolicy == null ? TerminusExpiryPolicy.SESSION_END : expiryPolicy; - } - - public final UnsignedInteger getTimeout() - { - return _timeout; - } - - public final void setTimeout(UnsignedInteger timeout) - { - _timeout = timeout; - } - - public final boolean getDynamic() - { - return _dynamic; - } - - public final void setDynamic(boolean dynamic) - { - _dynamic = dynamic; - } - - public final Map getDynamicNodeProperties() - { - return _dynamicNodeProperties; - } - - public final void setDynamicNodeProperties(Map dynamicNodeProperties) - { - _dynamicNodeProperties = dynamicNodeProperties; - } - - - public final Symbol[] getCapabilities() - { - return _capabilities; - } - - public final void setCapabilities(Symbol... capabilities) - { - _capabilities = capabilities; - } - -}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/TerminusDurability.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/TerminusDurability.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/TerminusDurability.java deleted file mode 100644 index 2c056d8..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/TerminusDurability.java +++ /dev/null @@ -1,52 +0,0 @@ - -/* -* -* 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.proton.amqp.messaging; - -import org.apache.qpid.proton.amqp.UnsignedInteger; - -public enum TerminusDurability -{ - NONE, CONFIGURATION, UNSETTLED_STATE; - - public UnsignedInteger getValue() - { - return UnsignedInteger.valueOf(ordinal()); - } - - public static TerminusDurability get(UnsignedInteger value) - { - - switch (value.intValue()) - { - case 0: - return NONE; - case 1: - return CONFIGURATION; - case 2: - return UNSETTLED_STATE; - } - throw new IllegalArgumentException("Unknown TerminusDurablity: " + value); - } - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/TerminusExpiryPolicy.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/TerminusExpiryPolicy.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/TerminusExpiryPolicy.java deleted file mode 100644 index 406c19a..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/messaging/TerminusExpiryPolicy.java +++ /dev/null @@ -1,67 +0,0 @@ - -/* -* -* 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.proton.amqp.messaging; - -import java.util.HashMap; -import java.util.Map; -import org.apache.qpid.proton.amqp.Symbol; - -public enum TerminusExpiryPolicy -{ - LINK_DETACH("link-detach"), - SESSION_END("session-end"), - CONNECTION_CLOSE("connection-close"), - NEVER("never"); - - private Symbol _policy; - private static final Map<Symbol, TerminusExpiryPolicy> _map = new HashMap<Symbol, TerminusExpiryPolicy>(); - - TerminusExpiryPolicy(String policy) - { - _policy = Symbol.valueOf(policy); - } - - public Symbol getPolicy() - { - return _policy; - } - - static - { - _map.put(LINK_DETACH.getPolicy(), LINK_DETACH); - _map.put(SESSION_END.getPolicy(), SESSION_END); - _map.put(CONNECTION_CLOSE.getPolicy(), CONNECTION_CLOSE); - _map.put(NEVER.getPolicy(), NEVER); - } - - public static TerminusExpiryPolicy valueOf(Symbol policy) - { - TerminusExpiryPolicy expiryPolicy = _map.get(policy); - if(expiryPolicy == null) - { - throw new IllegalArgumentException("Unknown TerminusExpiryPolicy: " + policy); - } - return expiryPolicy; - } -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslChallenge.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslChallenge.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslChallenge.java deleted file mode 100644 index 83246b4..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslChallenge.java +++ /dev/null @@ -1,80 +0,0 @@ - -/* -* -* 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.proton.amqp.security; - - -import org.apache.qpid.proton.amqp.Binary; - - -public final class SaslChallenge implements SaslFrameBody -{ - private Binary _challenge; - - public Binary getChallenge() - { - return _challenge; - } - - public void setChallenge(Binary challenge) - { - if( challenge == null ) - { - throw new NullPointerException("the challenge field is mandatory"); - } - - _challenge = challenge; - } - - public Object get(final int index) - { - - switch(index) - { - case 0: - return _challenge; - } - - throw new IllegalStateException("Unknown index " + index); - - } - - public int size() - { - return 1; - - } - - public <E> void invoke(SaslFrameBodyHandler<E> handler, Binary payload, E context) - { - handler.handleChallenge(this, payload, context); - } - - @Override - public String toString() - { - return "SaslChallenge{" + - "challenge=" + _challenge + - '}'; - } -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslCode.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslCode.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslCode.java deleted file mode 100644 index ad35da8..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslCode.java +++ /dev/null @@ -1,42 +0,0 @@ - -/* -* -* 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.proton.amqp.security; - -import org.apache.qpid.proton.amqp.UnsignedByte; - -public enum SaslCode -{ - OK, AUTH, SYS, SYS_PERM, SYS_TEMP; - - public UnsignedByte getValue() - { - return UnsignedByte.valueOf((byte)ordinal()); - } - - public static SaslCode valueOf(UnsignedByte v) - { - return SaslCode.values()[v.byteValue()]; - } - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslFrameBody.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslFrameBody.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslFrameBody.java deleted file mode 100644 index 3db2652..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslFrameBody.java +++ /dev/null @@ -1,37 +0,0 @@ -/* - * - * 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.proton.amqp.security; - -import org.apache.qpid.proton.amqp.Binary; - -public interface SaslFrameBody -{ - interface SaslFrameBodyHandler<E> - { - void handleMechanisms(SaslMechanisms saslMechanisms, Binary payload, E context); - void handleInit(SaslInit saslInit, Binary payload, E context); - void handleChallenge(SaslChallenge saslChallenge, Binary payload, E context); - void handleResponse(SaslResponse saslResponse, Binary payload, E context); - void handleOutcome(SaslOutcome saslOutcome, Binary payload, E context); - } - - <E> void invoke(SaslFrameBodyHandler<E> handler, Binary payload, E context); -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslInit.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslInit.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslInit.java deleted file mode 100644 index 1764d35..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslInit.java +++ /dev/null @@ -1,87 +0,0 @@ - -/* -* -* 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.proton.amqp.security; - -import org.apache.qpid.proton.amqp.Binary; -import org.apache.qpid.proton.amqp.Symbol; - -public final class SaslInit - implements SaslFrameBody -{ - - private Symbol _mechanism; - private Binary _initialResponse; - private String _hostname; - - public Symbol getMechanism() - { - return _mechanism; - } - - public void setMechanism(Symbol mechanism) - { - if( mechanism == null ) - { - throw new NullPointerException("the mechanism field is mandatory"); - } - - _mechanism = mechanism; - } - - public Binary getInitialResponse() - { - return _initialResponse; - } - - public void setInitialResponse(Binary initialResponse) - { - _initialResponse = initialResponse; - } - - public String getHostname() - { - return _hostname; - } - - public void setHostname(String hostname) - { - _hostname = hostname; - } - - - public <E> void invoke(SaslFrameBodyHandler<E> handler, Binary payload, E context) - { - handler.handleInit(this, payload, context); - } - - @Override - public String toString() - { - return "SaslInit{" + - "mechanism=" + _mechanism + - ", initialResponse=" + _initialResponse + - ", hostname='" + _hostname + '\'' + - '}'; - } -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslMechanisms.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslMechanisms.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslMechanisms.java deleted file mode 100644 index 7d51afd..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslMechanisms.java +++ /dev/null @@ -1,67 +0,0 @@ - -/* -* -* 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.proton.amqp.security; - -import java.util.Arrays; -import org.apache.qpid.proton.amqp.Binary; -import org.apache.qpid.proton.amqp.Symbol; - -public final class SaslMechanisms - implements SaslFrameBody -{ - - private Symbol[] _saslServerMechanisms; - - public Symbol[] getSaslServerMechanisms() - { - return _saslServerMechanisms; - } - - public void setSaslServerMechanisms(Symbol... saslServerMechanisms) - { - if( saslServerMechanisms == null ) - { - throw new NullPointerException("the sasl-server-mechanisms field is mandatory"); - } - - _saslServerMechanisms = saslServerMechanisms; - } - - - public <E> void invoke(SaslFrameBodyHandler<E> handler, Binary payload, E context) - { - handler.handleMechanisms(this, payload, context); - } - - - - @Override - public String toString() - { - return "SaslMechanisms{" + - "saslServerMechanisms=" + (_saslServerMechanisms == null ? null : Arrays.asList(_saslServerMechanisms)) - + - '}'; - } -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslOutcome.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslOutcome.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslOutcome.java deleted file mode 100644 index 9071145..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslOutcome.java +++ /dev/null @@ -1,80 +0,0 @@ - -/* -* -* 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.proton.amqp.security; - - - -import org.apache.qpid.proton.amqp.Binary; - - -public final class SaslOutcome - implements SaslFrameBody -{ - - private SaslCode _code; - private Binary _additionalData; - - public SaslCode getCode() - { - return _code; - } - - public void setCode(SaslCode code) - { - if( code == null ) - { - throw new NullPointerException("the code field is mandatory"); - } - - _code = code; - } - - public Binary getAdditionalData() - { - return _additionalData; - } - - public void setAdditionalData(Binary additionalData) - { - _additionalData = additionalData; - } - - - @Override - public String toString() - { - return "SaslOutcome{" + - "_code=" + _code + - ", _additionalData=" + _additionalData + - '}'; - } - - public <E> void invoke(SaslFrameBodyHandler<E> handler, Binary payload, E context) - { - handler.handleOutcome(this, payload, context); - } - - - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslResponse.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslResponse.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslResponse.java deleted file mode 100644 index e926e06..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/security/SaslResponse.java +++ /dev/null @@ -1,63 +0,0 @@ - -/* -* -* 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.proton.amqp.security; - -import org.apache.qpid.proton.amqp.Binary; - -public final class SaslResponse - implements SaslFrameBody -{ - - private Binary _response; - - public Binary getResponse() - { - return _response; - } - - public void setResponse(Binary response) - { - if( response == null ) - { - throw new NullPointerException("the response field is mandatory"); - } - - _response = response; - } - - - @Override - public String toString() - { - return "SaslResponse{response=" + _response + - '}'; - } - - public <E> void invoke(SaslFrameBodyHandler<E> handler, Binary payload, E context) - { - handler.handleResponse(this, payload, context); - } - - - } http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Coordinator.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Coordinator.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Coordinator.java deleted file mode 100644 index 7ff000a..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Coordinator.java +++ /dev/null @@ -1,64 +0,0 @@ - -/* -* -* 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.proton.amqp.transaction; - -import java.util.Arrays; -import org.apache.qpid.proton.amqp.Symbol; -import org.apache.qpid.proton.amqp.transport.Target; - - -public final class Coordinator - implements Target -{ - private Symbol[] _capabilities; - - public Symbol[] getCapabilities() - { - return _capabilities; - } - - public void setCapabilities(Symbol... capabilities) - { - _capabilities = capabilities; - } - - @Override - public String toString() - { - return "Coordinator{" + - "capabilities=" + (_capabilities == null ? null : Arrays.asList(_capabilities)) + - '}'; - } - - public String getAddress() - { - return null; - } - - @Override - public Target copy() { - return null; - } -} - http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declare.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declare.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declare.java deleted file mode 100644 index 714db5c..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declare.java +++ /dev/null @@ -1,49 +0,0 @@ - -/* -* -* 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.proton.amqp.transaction; - -public final class Declare -{ - - private GlobalTxId _globalId; - - public GlobalTxId getGlobalId() - { - return _globalId; - } - - public void setGlobalId(GlobalTxId globalId) - { - _globalId = globalId; - } - - @Override - public String toString() - { - return "Declare{" + - "globalId=" + _globalId + - '}'; - } -} - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declared.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declared.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declared.java deleted file mode 100644 index e049cd5..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Declared.java +++ /dev/null @@ -1,62 +0,0 @@ - -/* -* -* 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.proton.amqp.transaction; - -import org.apache.qpid.proton.amqp.Binary; -import org.apache.qpid.proton.amqp.Symbol; -import org.apache.qpid.proton.amqp.messaging.Outcome; -import org.apache.qpid.proton.amqp.transport.DeliveryState; - - -public final class Declared - implements DeliveryState, Outcome -{ - public static final Symbol DESCRIPTOR_SYMBOL = Symbol.valueOf("amqp:declared:list"); - - private Binary _txnId; - - public Binary getTxnId() - { - return _txnId; - } - - public void setTxnId(Binary txnId) - { - if( txnId == null ) - { - throw new NullPointerException("the txn-id field is mandatory"); - } - - _txnId = txnId; - } - - @Override - public String toString() - { - return "Declared{" + - "txnId=" + _txnId + - '}'; - } -} - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Discharge.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Discharge.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Discharge.java deleted file mode 100644 index 959d49b..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/Discharge.java +++ /dev/null @@ -1,68 +0,0 @@ - -/* -* -* 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.proton.amqp.transaction; - -import org.apache.qpid.proton.amqp.Binary; - -public final class Discharge -{ - - private Binary _txnId; - private Boolean _fail; - - public Binary getTxnId() - { - return _txnId; - } - - public void setTxnId(Binary txnId) - { - if( txnId == null ) - { - throw new NullPointerException("the txn-id field is mandatory"); - } - - _txnId = txnId; - } - - public Boolean getFail() - { - return _fail; - } - - public void setFail(Boolean fail) - { - _fail = fail; - } - - @Override - public String toString() - { - return "Discharge{" + - "txnId=" + _txnId + - ", fail=" + _fail + - '}'; - } -} - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/GlobalTxId.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/GlobalTxId.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/GlobalTxId.java deleted file mode 100644 index 3724893..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/GlobalTxId.java +++ /dev/null @@ -1,25 +0,0 @@ -/* - * - * 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.proton.amqp.transaction; - -public interface GlobalTxId -{ -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/TransactionErrors.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/TransactionErrors.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/TransactionErrors.java deleted file mode 100644 index d304e26..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/TransactionErrors.java +++ /dev/null @@ -1,36 +0,0 @@ - -/* -* -* 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.proton.amqp.transaction; - -import org.apache.qpid.proton.amqp.Symbol; - -public interface TransactionErrors -{ - final static Symbol UNKNOWN_ID = Symbol.valueOf("amqp:transaction:unknown-id"); - - final static Symbol TRANSACTION_ROLLBACK = Symbol.valueOf("amqp:transaction:rollback"); - - final static Symbol TRANSACTION_TIMEOUT = Symbol.valueOf("amqp:transaction:timeout"); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/TransactionalState.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/TransactionalState.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/TransactionalState.java deleted file mode 100644 index 313d846..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/TransactionalState.java +++ /dev/null @@ -1,71 +0,0 @@ - -/* -* -* 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.proton.amqp.transaction; - -import org.apache.qpid.proton.amqp.Binary; -import org.apache.qpid.proton.amqp.transport.DeliveryState; -import org.apache.qpid.proton.amqp.messaging.Outcome; - -public final class TransactionalState - implements DeliveryState -{ - - private Binary _txnId; - private Outcome _outcome; - - public Binary getTxnId() - { - return _txnId; - } - - public void setTxnId(Binary txnId) - { - if( txnId == null ) - { - throw new NullPointerException("the txn-id field is mandatory"); - } - - _txnId = txnId; - } - - public Outcome getOutcome() - { - return _outcome; - } - - public void setOutcome(Outcome outcome) - { - _outcome = outcome; - } - - @Override - public String toString() - { - return "TransactionalState{" + - "txnId=" + _txnId + - ", outcome=" + _outcome + - '}'; - } -} - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/TxnCapability.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/TxnCapability.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/TxnCapability.java deleted file mode 100644 index 544f43e..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transaction/TxnCapability.java +++ /dev/null @@ -1,40 +0,0 @@ - -/* -* -* 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.proton.amqp.transaction; - -import org.apache.qpid.proton.amqp.Symbol; - -public interface TxnCapability -{ - final static Symbol LOCAL_TXN = Symbol.valueOf("amqp:local-transactions"); - - final static Symbol DISTRIBUTED_TXN = Symbol.valueOf("amqp:distributed-transactions"); - - final static Symbol PROMOTABLE_TXN = Symbol.valueOf("amqp:promotable-transactions"); - - final static Symbol MULTI_TXNS_PER_SSN = Symbol.valueOf("amqp:multi-txns-per-ssn"); - - final static Symbol MULTI_SSNS_PER_TXN = Symbol.valueOf("amqp:multi-ssns-per-txn"); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/AmqpError.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/AmqpError.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/AmqpError.java deleted file mode 100644 index 90be358..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/AmqpError.java +++ /dev/null @@ -1,56 +0,0 @@ - -/* -* -* 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.proton.amqp.transport; - -import org.apache.qpid.proton.amqp.Symbol; - -public interface AmqpError -{ - final static Symbol INTERNAL_ERROR = Symbol.valueOf("amqp:internal-error"); - - final static Symbol NOT_FOUND = Symbol.valueOf("amqp:not-found"); - - final static Symbol UNAUTHORIZED_ACCESS = Symbol.valueOf("amqp:unauthorized-access"); - - final static Symbol DECODE_ERROR = Symbol.valueOf("amqp:decode-error"); - - final static Symbol RESOURCE_LIMIT_EXCEEDED = Symbol.valueOf("amqp:resource-limit-exceeded"); - - final static Symbol NOT_ALLOWED = Symbol.valueOf("amqp:not-allowed"); - - final static Symbol INVALID_FIELD = Symbol.valueOf("amqp:invalid-field"); - - final static Symbol NOT_IMPLEMENTED = Symbol.valueOf("amqp:not-implemented"); - - final static Symbol RESOURCE_LOCKED = Symbol.valueOf("amqp:resource-locked"); - - final static Symbol PRECONDITION_FAILED = Symbol.valueOf("amqp:precondition-failed"); - - final static Symbol RESOURCE_DELETED = Symbol.valueOf("amqp:resource-deleted"); - - final static Symbol ILLEGAL_STATE = Symbol.valueOf("amqp:illegal-state"); - - final static Symbol FRAME_SIZE_TOO_SMALL = Symbol.valueOf("amqp:frame-size-too-small"); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Attach.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Attach.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Attach.java deleted file mode 100644 index 1d1746f..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Attach.java +++ /dev/null @@ -1,232 +0,0 @@ - -/* -* -* 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.proton.amqp.transport; - -import org.apache.qpid.proton.amqp.Binary; -import org.apache.qpid.proton.amqp.Symbol; -import org.apache.qpid.proton.amqp.UnsignedInteger; -import org.apache.qpid.proton.amqp.UnsignedLong; - -import java.util.Arrays; -import java.util.Map; - -public final class Attach implements FrameBody -{ - - private String _name; - private UnsignedInteger _handle; - private Role _role = Role.SENDER; - private SenderSettleMode _sndSettleMode = SenderSettleMode.MIXED; - private ReceiverSettleMode _rcvSettleMode = ReceiverSettleMode.FIRST; - private Source _source; - private Target _target; - private Map _unsettled; - private boolean _incompleteUnsettled; - private UnsignedInteger _initialDeliveryCount; - private UnsignedLong _maxMessageSize; - private Symbol[] _offeredCapabilities; - private Symbol[] _desiredCapabilities; - private Map _properties; - - public String getName() - { - return _name; - } - - public void setName(String name) - { - if( name == null ) - { - throw new NullPointerException("the name field is mandatory"); - } - - _name = name; - } - - public UnsignedInteger getHandle() - { - return _handle; - } - - public void setHandle(UnsignedInteger handle) - { - if( handle == null ) - { - throw new NullPointerException("the handle field is mandatory"); - } - - _handle = handle; - } - - public Role getRole() - { - return _role; - } - - public void setRole(Role role) - { - if(role == null) - { - throw new NullPointerException("Role cannot be null"); - } - _role = role; - } - - public SenderSettleMode getSndSettleMode() - { - return _sndSettleMode; - } - - public void setSndSettleMode(SenderSettleMode sndSettleMode) - { - _sndSettleMode = sndSettleMode == null ? SenderSettleMode.MIXED : sndSettleMode; - } - - public ReceiverSettleMode getRcvSettleMode() - { - return _rcvSettleMode; - } - - public void setRcvSettleMode(ReceiverSettleMode rcvSettleMode) - { - _rcvSettleMode = rcvSettleMode == null ? ReceiverSettleMode.FIRST : rcvSettleMode; - } - - public Source getSource() - { - return _source; - } - - public void setSource(Source source) - { - _source = source; - } - - public Target getTarget() - { - return _target; - } - - public void setTarget(Target target) - { - _target = target; - } - - public Map getUnsettled() - { - return _unsettled; - } - - public void setUnsettled(Map unsettled) - { - _unsettled = unsettled; - } - - public boolean getIncompleteUnsettled() - { - return _incompleteUnsettled; - } - - public void setIncompleteUnsettled(boolean incompleteUnsettled) - { - _incompleteUnsettled = incompleteUnsettled; - } - - public UnsignedInteger getInitialDeliveryCount() - { - return _initialDeliveryCount; - } - - public void setInitialDeliveryCount(UnsignedInteger initialDeliveryCount) - { - _initialDeliveryCount = initialDeliveryCount; - } - - public UnsignedLong getMaxMessageSize() - { - return _maxMessageSize; - } - - public void setMaxMessageSize(UnsignedLong maxMessageSize) - { - _maxMessageSize = maxMessageSize; - } - - public Symbol[] getOfferedCapabilities() - { - return _offeredCapabilities; - } - - public void setOfferedCapabilities(Symbol... offeredCapabilities) - { - _offeredCapabilities = offeredCapabilities; - } - - public Symbol[] getDesiredCapabilities() - { - return _desiredCapabilities; - } - - public void setDesiredCapabilities(Symbol... desiredCapabilities) - { - _desiredCapabilities = desiredCapabilities; - } - - public Map getProperties() - { - return _properties; - } - - public void setProperties(Map properties) - { - _properties = properties; - } - - public <E> void invoke(FrameBodyHandler<E> handler, Binary payload, E context) - { - handler.handleAttach(this, payload, context); - } - - - @Override - public String toString() - { - return "Attach{" + - "name='" + _name + '\'' + - ", handle=" + _handle + - ", role=" + _role + - ", sndSettleMode=" + _sndSettleMode + - ", rcvSettleMode=" + _rcvSettleMode + - ", source=" + _source + - ", target=" + _target + - ", unsettled=" + _unsettled + - ", incompleteUnsettled=" + _incompleteUnsettled + - ", initialDeliveryCount=" + _initialDeliveryCount + - ", maxMessageSize=" + _maxMessageSize + - ", offeredCapabilities=" + (_offeredCapabilities == null ? null : Arrays.asList(_offeredCapabilities)) + - ", desiredCapabilities=" + (_desiredCapabilities == null ? null : Arrays.asList(_desiredCapabilities)) + - ", properties=" + _properties + - '}'; - } -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Begin.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Begin.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Begin.java deleted file mode 100644 index ead4050..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Begin.java +++ /dev/null @@ -1,163 +0,0 @@ - -/* -* -* 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.proton.amqp.transport; - -import org.apache.qpid.proton.amqp.Binary; -import org.apache.qpid.proton.amqp.Symbol; -import org.apache.qpid.proton.amqp.UnsignedInteger; -import org.apache.qpid.proton.amqp.UnsignedShort; - -import java.util.Arrays; -import java.util.Map; - - -public final class Begin implements FrameBody -{ - - private UnsignedShort _remoteChannel; - private UnsignedInteger _nextOutgoingId; - private UnsignedInteger _incomingWindow; - private UnsignedInteger _outgoingWindow; - private UnsignedInteger _handleMax = UnsignedInteger.valueOf(0xffffffff); - private Symbol[] _offeredCapabilities; - private Symbol[] _desiredCapabilities; - private Map _properties; - - public UnsignedShort getRemoteChannel() - { - return _remoteChannel; - } - - public void setRemoteChannel(UnsignedShort remoteChannel) - { - _remoteChannel = remoteChannel; - } - - public UnsignedInteger getNextOutgoingId() - { - return _nextOutgoingId; - } - - public void setNextOutgoingId(UnsignedInteger nextOutgoingId) - { - if( nextOutgoingId == null ) - { - throw new NullPointerException("the next-outgoing-id field is mandatory"); - } - - _nextOutgoingId = nextOutgoingId; - } - - public UnsignedInteger getIncomingWindow() - { - return _incomingWindow; - } - - public void setIncomingWindow(UnsignedInteger incomingWindow) - { - if( incomingWindow == null ) - { - throw new NullPointerException("the incoming-window field is mandatory"); - } - - _incomingWindow = incomingWindow; - } - - public UnsignedInteger getOutgoingWindow() - { - return _outgoingWindow; - } - - public void setOutgoingWindow(UnsignedInteger outgoingWindow) - { - if( outgoingWindow == null ) - { - throw new NullPointerException("the outgoing-window field is mandatory"); - } - - _outgoingWindow = outgoingWindow; - } - - public UnsignedInteger getHandleMax() - { - return _handleMax; - } - - public void setHandleMax(UnsignedInteger handleMax) - { - _handleMax = handleMax; - } - - public Symbol[] getOfferedCapabilities() - { - return _offeredCapabilities; - } - - public void setOfferedCapabilities(Symbol... offeredCapabilities) - { - _offeredCapabilities = offeredCapabilities; - } - - public Symbol[] getDesiredCapabilities() - { - return _desiredCapabilities; - } - - public void setDesiredCapabilities(Symbol... desiredCapabilities) - { - _desiredCapabilities = desiredCapabilities; - } - - public Map getProperties() - { - return _properties; - } - - public void setProperties(Map properties) - { - _properties = properties; - } - - public <E> void invoke(FrameBodyHandler<E> handler, Binary payload, E context) - { - handler.handleBegin(this, payload, context); - } - - - @Override - public String toString() - { - return "Begin{" + - "remoteChannel=" + _remoteChannel + - ", nextOutgoingId=" + _nextOutgoingId + - ", incomingWindow=" + _incomingWindow + - ", outgoingWindow=" + _outgoingWindow + - ", handleMax=" + _handleMax + - ", offeredCapabilities=" + (_offeredCapabilities == null ? null : Arrays.asList(_offeredCapabilities)) + - ", desiredCapabilities=" + (_desiredCapabilities == null ? null : Arrays.asList(_desiredCapabilities)) + - ", properties=" + _properties + - '}'; - } -} - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Close.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Close.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Close.java deleted file mode 100644 index ca141f8..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Close.java +++ /dev/null @@ -1,55 +0,0 @@ - -/* -* -* 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.proton.amqp.transport; - -import org.apache.qpid.proton.amqp.Binary; - -public final class Close implements FrameBody -{ - private ErrorCondition _error; - - public ErrorCondition getError() - { - return _error; - } - - public void setError(ErrorCondition error) - { - _error = error; - } - - public <E> void invoke(FrameBodyHandler<E> handler, Binary payload, E context) - { - handler.handleClose(this, payload, context); - } - - @Override - public String toString() - { - return "Close{" + - "error=" + _error + - '}'; - } -} - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/ConnectionError.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/ConnectionError.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/ConnectionError.java deleted file mode 100644 index d31ebf7..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/ConnectionError.java +++ /dev/null @@ -1,36 +0,0 @@ - -/* -* -* 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.proton.amqp.transport; - -import org.apache.qpid.proton.amqp.Symbol; - -public interface ConnectionError -{ - final static Symbol CONNECTION_FORCED = Symbol.valueOf("amqp:connection:forced"); - - final static Symbol FRAMING_ERROR = Symbol.valueOf("amqp:connection:framing-error"); - - final static Symbol REDIRECT = Symbol.valueOf("amqp:connection:redirect"); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/DeliveryState.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/DeliveryState.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/DeliveryState.java deleted file mode 100644 index 4fa9806..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/DeliveryState.java +++ /dev/null @@ -1,33 +0,0 @@ -/* - * - * 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.proton.amqp.transport; - -/** - * Describes the state of a delivery at a link end-point. - * - * Note that the the sender is the owner of the state. - * The receiver merely influences the state. - * TODO clarify the concept of ownership? how is link recovery involved? - */ -public interface DeliveryState -{ - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Detach.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Detach.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Detach.java deleted file mode 100644 index b0f2936..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Detach.java +++ /dev/null @@ -1,86 +0,0 @@ - -/* -* -* 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.proton.amqp.transport; - -import org.apache.qpid.proton.amqp.Binary; -import org.apache.qpid.proton.amqp.UnsignedInteger; - -public final class Detach implements FrameBody -{ - - private UnsignedInteger _handle; - private boolean _closed; - private ErrorCondition _error; - - public UnsignedInteger getHandle() - { - return _handle; - } - - public void setHandle(UnsignedInteger handle) - { - if( handle == null ) - { - throw new NullPointerException("the handle field is mandatory"); - } - - _handle = handle; - } - - public boolean getClosed() - { - return _closed; - } - - public void setClosed(boolean closed) - { - _closed = closed; - } - - public ErrorCondition getError() - { - return _error; - } - - public void setError(ErrorCondition error) - { - _error = error; - } - - public <E> void invoke(FrameBodyHandler<E> handler, Binary payload, E context) - { - handler.handleDetach(this, payload, context); - } - - @Override - public String toString() - { - return "Detach{" + - "handle=" + _handle + - ", closed=" + _closed + - ", error=" + _error + - '}'; - } -} - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Disposition.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Disposition.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Disposition.java deleted file mode 100644 index a850940..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Disposition.java +++ /dev/null @@ -1,124 +0,0 @@ - -/* -* -* 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.proton.amqp.transport; - -import org.apache.qpid.proton.amqp.Binary; -import org.apache.qpid.proton.amqp.UnsignedInteger; - -public final class Disposition implements FrameBody -{ - private Role _role = Role.SENDER; - private UnsignedInteger _first; - private UnsignedInteger _last; - private boolean _settled; - private DeliveryState _state; - private boolean _batchable; - - public Role getRole() - { - return _role; - } - - public void setRole(Role role) - { - if(role == null) - { - throw new NullPointerException("Role cannot be null"); - } - _role = role; - } - - public UnsignedInteger getFirst() - { - return _first; - } - - public void setFirst(UnsignedInteger first) - { - if( first == null ) - { - throw new NullPointerException("the first field is mandatory"); - } - - _first = first; - } - - public UnsignedInteger getLast() - { - return _last; - } - - public void setLast(UnsignedInteger last) - { - _last = last; - } - - public boolean getSettled() - { - return _settled; - } - - public void setSettled(boolean settled) - { - _settled = settled; - } - - public DeliveryState getState() - { - return _state; - } - - public void setState(DeliveryState state) - { - _state = state; - } - - public boolean getBatchable() - { - return _batchable; - } - - public void setBatchable(boolean batchable) - { - _batchable = batchable; - } - - public <E> void invoke(FrameBodyHandler<E> handler, Binary payload, E context) - { - handler.handleDisposition(this, payload, context); - } - - @Override - public String toString() - { - return "Disposition{" + - "role=" + _role + - ", first=" + _first + - ", last=" + _last + - ", settled=" + _settled + - ", state=" + _state + - ", batchable=" + _batchable + - '}'; - } -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/EmptyFrame.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/EmptyFrame.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/EmptyFrame.java deleted file mode 100644 index b085e84..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/EmptyFrame.java +++ /dev/null @@ -1,38 +0,0 @@ -/* -* -* 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.proton.amqp.transport; - -import org.apache.qpid.proton.amqp.Binary; - -public final class EmptyFrame implements FrameBody -{ - @Override - public <E> void invoke(FrameBodyHandler<E> handler, Binary payload, E context) - { - // NO-OP - } - - @Override - public String toString() - { - return "Empty Frame"; - } -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/End.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/End.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/End.java deleted file mode 100644 index e53a456..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/End.java +++ /dev/null @@ -1,55 +0,0 @@ - -/* -* -* 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.proton.amqp.transport; - -import org.apache.qpid.proton.amqp.Binary; - -public final class End implements FrameBody -{ - private ErrorCondition _error; - - public ErrorCondition getError() - { - return _error; - } - - public void setError(ErrorCondition error) - { - _error = error; - } - - public <E> void invoke(FrameBodyHandler<E> handler, Binary payload, E context) - { - handler.handleEnd(this, payload, context); - } - - @Override - public String toString() - { - return "End{" + - "error=" + _error + - '}'; - } -} - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/ErrorCondition.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/ErrorCondition.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/ErrorCondition.java deleted file mode 100644 index abebc21..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/ErrorCondition.java +++ /dev/null @@ -1,145 +0,0 @@ - -/* -* -* 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.proton.amqp.transport; - -import java.util.Map; - -import org.apache.qpid.proton.amqp.Symbol; - - -public final class ErrorCondition -{ - private Symbol _condition; - private String _description; - private Map _info; - - public ErrorCondition() - { - } - - public ErrorCondition(Symbol condition, String description) - { - _condition = condition; - _description = description; - } - - public Symbol getCondition() - { - return _condition; - } - - public void setCondition(Symbol condition) - { - if( condition == null ) - { - throw new NullPointerException("the condition field is mandatory"); - } - - _condition = condition; - } - - public String getDescription() - { - return _description; - } - - public void setDescription(String description) - { - _description = description; - } - - public Map getInfo() - { - return _info; - } - - public void setInfo(Map info) - { - _info = info; - } - - public void clear() - { - _condition = null; - _description = null; - _info = null; - } - - public void copyFrom(ErrorCondition condition) - { - _condition = condition._condition; - _description = condition._description; - _info = condition._info; - } - - @Override - public boolean equals(Object o) - { - if (this == o) - { - return true; - } - if (o == null || getClass() != o.getClass()) - { - return false; - } - - ErrorCondition that = (ErrorCondition) o; - - if (_condition != null ? !_condition.equals(that._condition) : that._condition != null) - { - return false; - } - if (_description != null ? !_description.equals(that._description) : that._description != null) - { - return false; - } - if (_info != null ? !_info.equals(that._info) : that._info != null) - { - return false; - } - - return true; - } - - @Override - public int hashCode() - { - int result = _condition != null ? _condition.hashCode() : 0; - result = 31 * result + (_description != null ? _description.hashCode() : 0); - result = 31 * result + (_info != null ? _info.hashCode() : 0); - return result; - } - - @Override - public String toString() - { - return "Error{" + - "condition=" + _condition + - ", description='" + _description + '\'' + - ", info=" + _info + - '}'; - } -} - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Flow.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Flow.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Flow.java deleted file mode 100644 index b421a00..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/Flow.java +++ /dev/null @@ -1,193 +0,0 @@ - -/* -* -* 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.proton.amqp.transport; - -import java.util.Map; - -import org.apache.qpid.proton.amqp.Binary; -import org.apache.qpid.proton.amqp.UnsignedInteger; - -public final class Flow implements FrameBody -{ - private UnsignedInteger _nextIncomingId; - private UnsignedInteger _incomingWindow; - private UnsignedInteger _nextOutgoingId; - private UnsignedInteger _outgoingWindow; - private UnsignedInteger _handle; - private UnsignedInteger _deliveryCount; - private UnsignedInteger _linkCredit; - private UnsignedInteger _available; - private boolean _drain; - private boolean _echo; - private Map _properties; - - public UnsignedInteger getNextIncomingId() - { - return _nextIncomingId; - } - - public void setNextIncomingId(UnsignedInteger nextIncomingId) - { - _nextIncomingId = nextIncomingId; - } - - public UnsignedInteger getIncomingWindow() - { - return _incomingWindow; - } - - public void setIncomingWindow(UnsignedInteger incomingWindow) - { - if( incomingWindow == null ) - { - throw new NullPointerException("the incoming-window field is mandatory"); - } - - _incomingWindow = incomingWindow; - } - - public UnsignedInteger getNextOutgoingId() - { - return _nextOutgoingId; - } - - public void setNextOutgoingId(UnsignedInteger nextOutgoingId) - { - if( nextOutgoingId == null ) - { - throw new NullPointerException("the next-outgoing-id field is mandatory"); - } - - _nextOutgoingId = nextOutgoingId; - } - - public UnsignedInteger getOutgoingWindow() - { - return _outgoingWindow; - } - - public void setOutgoingWindow(UnsignedInteger outgoingWindow) - { - if( outgoingWindow == null ) - { - throw new NullPointerException("the outgoing-window field is mandatory"); - } - - _outgoingWindow = outgoingWindow; - } - - public UnsignedInteger getHandle() - { - return _handle; - } - - public void setHandle(UnsignedInteger handle) - { - _handle = handle; - } - - public UnsignedInteger getDeliveryCount() - { - return _deliveryCount; - } - - public void setDeliveryCount(UnsignedInteger deliveryCount) - { - _deliveryCount = deliveryCount; - } - - public UnsignedInteger getLinkCredit() - { - return _linkCredit; - } - - public void setLinkCredit(UnsignedInteger linkCredit) - { - _linkCredit = linkCredit; - } - - public UnsignedInteger getAvailable() - { - return _available; - } - - public void setAvailable(UnsignedInteger available) - { - _available = available; - } - - public boolean getDrain() - { - return _drain; - } - - public void setDrain(boolean drain) - { - _drain = drain; - } - - public boolean getEcho() - { - return _echo; - } - - public void setEcho(boolean echo) - { - _echo = echo; - } - - public Map getProperties() - { - return _properties; - } - - public void setProperties(Map properties) - { - _properties = properties; - } - - public <E> void invoke(FrameBodyHandler<E> handler, Binary payload, E context) - { - handler.handleFlow(this, payload, context); - } - - @Override - public String toString() - { - return "Flow{" + - "nextIncomingId=" + _nextIncomingId + - ", incomingWindow=" + _incomingWindow + - ", nextOutgoingId=" + _nextOutgoingId + - ", outgoingWindow=" + _outgoingWindow + - ", handle=" + _handle + - ", deliveryCount=" + _deliveryCount + - ", linkCredit=" + _linkCredit + - ", available=" + _available + - ", drain=" + _drain + - ", echo=" + _echo + - ", properties=" + _properties + - '}'; - } -} - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/FrameBody.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/FrameBody.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/FrameBody.java deleted file mode 100644 index 90a2431..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/FrameBody.java +++ /dev/null @@ -1,43 +0,0 @@ -package org.apache.qpid.proton.amqp.transport; -/* - * - * 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. - * -*/ - - -import org.apache.qpid.proton.amqp.Binary; - -public interface FrameBody -{ - interface FrameBodyHandler<E> - { - void handleOpen(Open open, Binary payload, E context); - void handleBegin(Begin begin, Binary payload, E context); - void handleAttach(Attach attach, Binary payload, E context); - void handleFlow(Flow flow, Binary payload, E context); - void handleTransfer(Transfer transfer, Binary payload, E context); - void handleDisposition(Disposition disposition, Binary payload, E context); - void handleDetach(Detach detach, Binary payload, E context); - void handleEnd(End end, Binary payload, E context); - void handleClose(Close close, Binary payload, E context); - - } - - <E> void invoke(FrameBodyHandler<E> handler, Binary payload, E context); -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/LinkError.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/LinkError.java b/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/LinkError.java deleted file mode 100644 index 55294f0..0000000 --- a/proton-j/src/main/java/org/apache/qpid/proton/amqp/transport/LinkError.java +++ /dev/null @@ -1,40 +0,0 @@ - -/* -* -* 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.proton.amqp.transport; - -import org.apache.qpid.proton.amqp.Symbol; - -public interface LinkError -{ - final static Symbol DETACH_FORCED = Symbol.valueOf("amqp:link:detach-forced"); - - final static Symbol TRANSFER_LIMIT_EXCEEDED = Symbol.valueOf("amqp:link:transfer-limit-exceeded"); - - final static Symbol MESSAGE_SIZE_EXCEEDED = Symbol.valueOf("amqp:link:message-size-exceeded"); - - final static Symbol REDIRECT = Symbol.valueOf("amqp:link:redirect"); - - final static Symbol STOLEN = Symbol.valueOf("amqp:link:stolen"); - -} --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
