You are viewing a plain text version of this content. The canonical link for it is here.
Posted to scm@geronimo.apache.org by rm...@apache.org on 2015/01/02 14:18:23 UTC
svn commit: r1649017 [2/3] - in /geronimo/specs/trunk/geronimo-jms_2.0_spec:
./ src/ src/main/ src/main/java/ src/main/java/javax/
src/main/java/javax/jms/ src/test/ src/test/java/ src/test/java/javax/
src/test/java/javax/jms/
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSRuntimeException.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSRuntimeException.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSRuntimeException.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSRuntimeException.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,44 @@
+/*
+ * 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 javax.jms;
+
+/**
+ * Created by johnament on 10/5/14.
+ */
+public class JMSRuntimeException extends RuntimeException {
+ private String errorCode;
+ public JMSRuntimeException(String message) {
+ super(message);
+ }
+
+ public JMSRuntimeException(String message, String errorCode) {
+ this(message);
+ this.errorCode = errorCode;
+ }
+
+ public JMSRuntimeException(String message, String errorCode, Throwable cause) {
+ super(message, cause);
+ this.errorCode = errorCode;
+ }
+
+ public String getErrorCode() {
+ return this.errorCode;
+ }
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSSecurityException.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSSecurityException.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSSecurityException.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSSecurityException.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,39 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public class JMSSecurityException extends JMSException {
+ public JMSSecurityException(String reason, String errorCode) {
+ super(reason, errorCode);
+ }
+
+ public JMSSecurityException(String reason) {
+ this(reason, null);
+ }
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSSecurityRuntimeException.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSSecurityRuntimeException.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSSecurityRuntimeException.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSSecurityRuntimeException.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,34 @@
+/*
+ * 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 javax.jms;
+
+public class JMSSecurityRuntimeException extends JMSRuntimeException {
+ public JMSSecurityRuntimeException(String message) {
+ super(message);
+ }
+
+ public JMSSecurityRuntimeException(String message, String errorCode) {
+ super(message, errorCode);
+ }
+
+ public JMSSecurityRuntimeException(String message, String errorCode, Throwable cause) {
+ super(message, errorCode, cause);
+ }
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSSessionMode.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSSessionMode.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSSessionMode.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/JMSSessionMode.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,32 @@
+/*
+ * 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 javax.jms;
+
+import java.lang.annotation.Retention;
+import java.lang.annotation.Target;
+
+import static java.lang.annotation.ElementType.*;
+import static java.lang.annotation.RetentionPolicy.RUNTIME;
+
+@Retention(RUNTIME)
+@Target({METHOD, FIELD, PARAMETER, TYPE})
+public @interface JMSSessionMode {
+ int value() default JMSContext.AUTO_ACKNOWLEDGE;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MapMessage.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MapMessage.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MapMessage.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MapMessage.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,84 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+import java.util.Enumeration;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface MapMessage extends Message {
+ boolean getBoolean(String name) throws JMSException;
+
+ byte getByte(String name) throws JMSException;
+
+ short getShort(String name) throws JMSException;
+
+ char getChar(String name) throws JMSException;
+
+ int getInt(String name) throws JMSException;
+
+ long getLong(String name) throws JMSException;
+
+ float getFloat(String name) throws JMSException;
+
+ double getDouble(String name) throws JMSException;
+
+ String getString(String name) throws JMSException;
+
+ byte[] getBytes(String name) throws JMSException;
+
+ Object getObject(String name) throws JMSException;
+
+ Enumeration getMapNames() throws JMSException;
+
+ void setBoolean(String name, boolean value) throws JMSException;
+
+ void setByte(String name, byte value) throws JMSException;
+
+ void setShort(String name, short value) throws JMSException;
+
+ void setChar(String name, char value) throws JMSException;
+
+ void setInt(String name, int value) throws JMSException;
+
+ void setLong(String name, long value) throws JMSException;
+
+ void setFloat(String name, float value) throws JMSException;
+
+ void setDouble(String name, double value) throws JMSException;
+
+ void setString(String name, String value) throws JMSException;
+
+ void setBytes(String name, byte[] value) throws JMSException;
+
+ void setBytes(String name, byte[] value, int offset, int length)
+ throws JMSException;
+
+ void setObject(String name, Object value) throws JMSException;
+
+ boolean itemExists(String name) throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Message.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Message.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Message.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Message.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,140 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+import java.util.Enumeration;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface Message {
+
+ static final int DEFAULT_DELIVERY_MODE = DeliveryMode.PERSISTENT;
+
+ static final int DEFAULT_PRIORITY = 4;
+
+ static final long DEFAULT_TIME_TO_LIVE = 0;
+
+ static final long DEFAULT_DELIVERY_DELAY = 0l;
+
+ String getJMSMessageID() throws JMSException;
+
+ void setJMSMessageID(String id) throws JMSException;
+
+ long getJMSTimestamp() throws JMSException;
+
+ void setJMSTimestamp(long timestamp) throws JMSException;
+
+ byte[] getJMSCorrelationIDAsBytes() throws JMSException;
+
+ void setJMSCorrelationIDAsBytes(byte[] correlationID) throws JMSException;
+
+ void setJMSCorrelationID(String correlationID) throws JMSException;
+
+ String getJMSCorrelationID() throws JMSException;
+
+ Destination getJMSReplyTo() throws JMSException;
+
+ void setJMSReplyTo(Destination replyTo) throws JMSException;
+
+ Destination getJMSDestination() throws JMSException;
+
+ void setJMSDestination(Destination destination) throws JMSException;
+
+ int getJMSDeliveryMode() throws JMSException;
+
+ void setJMSDeliveryMode(int deliveryMode) throws JMSException;
+
+ boolean getJMSRedelivered() throws JMSException;
+
+ void setJMSRedelivered(boolean redelivered) throws JMSException;
+
+ String getJMSType() throws JMSException;
+
+ void setJMSType(String type) throws JMSException;
+
+ long getJMSExpiration() throws JMSException;
+
+ void setJMSExpiration(long expiration) throws JMSException;
+
+ int getJMSPriority() throws JMSException;
+
+ void setJMSPriority(int priority) throws JMSException;
+
+ void clearProperties() throws JMSException;
+
+ boolean propertyExists(String name) throws JMSException;
+
+ boolean getBooleanProperty(String name) throws JMSException;
+
+ byte getByteProperty(String name) throws JMSException;
+
+ short getShortProperty(String name) throws JMSException;
+
+ int getIntProperty(String name) throws JMSException;
+
+ long getLongProperty(String name) throws JMSException;
+
+ float getFloatProperty(String name) throws JMSException;
+
+ double getDoubleProperty(String name) throws JMSException;
+
+ String getStringProperty(String name) throws JMSException;
+
+ Object getObjectProperty(String name) throws JMSException;
+
+ Enumeration getPropertyNames() throws JMSException;
+
+ void setBooleanProperty(String name, boolean value) throws JMSException;
+
+ void setByteProperty(String name, byte value) throws JMSException;
+
+ void setShortProperty(String name, short value) throws JMSException;
+
+ void setIntProperty(String name, int value) throws JMSException;
+
+ void setLongProperty(String name, long value) throws JMSException;
+
+ void setFloatProperty(String name, float value) throws JMSException;
+
+ void setDoubleProperty(String name, double value) throws JMSException;
+
+ void setStringProperty(String name, String value) throws JMSException;
+
+ void setObjectProperty(String name, Object value) throws JMSException;
+
+ void acknowledge() throws JMSException;
+
+ void clearBody() throws JMSException;
+
+ long getJMSDeliveryTime() throws JMSException;
+
+ void setJMSDeliveryTime(long deliveryTime) throws JMSException;
+
+ <T> T getBody(Class<T> c) throws JMSException;
+
+ boolean isBodyAssignableTo(Class c) throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageConsumer.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageConsumer.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageConsumer.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageConsumer.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,45 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface MessageConsumer {
+ String getMessageSelector() throws JMSException;
+
+ MessageListener getMessageListener() throws JMSException;
+
+ void setMessageListener(MessageListener listener) throws JMSException;
+
+ Message receive() throws JMSException;
+
+ Message receive(long timeout) throws JMSException;
+
+ Message receiveNoWait() throws JMSException;
+
+ void close() throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageEOFException.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageEOFException.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageEOFException.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageEOFException.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,39 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public class MessageEOFException extends JMSException {
+ public MessageEOFException(String reason, String errorCode) {
+ super(reason, errorCode);
+ }
+
+ public MessageEOFException(String reason) {
+ this(reason, null);
+ }
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageFormatException.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageFormatException.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageFormatException.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageFormatException.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,39 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public class MessageFormatException extends JMSException {
+ public MessageFormatException(String reason, String errorCode) {
+ super(reason, errorCode);
+ }
+
+ public MessageFormatException(String reason) {
+ this(reason, null);
+ }
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageListener.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageListener.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageListener.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageListener.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,33 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface MessageListener {
+ void onMessage(Message message);
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageNotReadableException.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageNotReadableException.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageNotReadableException.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageNotReadableException.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,39 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public class MessageNotReadableException extends JMSException {
+ public MessageNotReadableException(String reason, String errorCode) {
+ super(reason, errorCode);
+ }
+
+ public MessageNotReadableException(String reason) {
+ this(reason, null);
+ }
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageNotWriteableException.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageNotWriteableException.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageNotWriteableException.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageNotWriteableException.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,39 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public class MessageNotWriteableException extends JMSException {
+ public MessageNotWriteableException(String reason, String errorCode) {
+ super(reason, errorCode);
+ }
+
+ public MessageNotWriteableException(String reason) {
+ this(reason, null);
+ }
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageNotWriteableRuntimeException.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageNotWriteableRuntimeException.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageNotWriteableRuntimeException.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageNotWriteableRuntimeException.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,34 @@
+/*
+ * 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 javax.jms;
+
+public class MessageNotWriteableRuntimeException extends JMSRuntimeException {
+ public MessageNotWriteableRuntimeException(String message) {
+ super(message);
+ }
+
+ public MessageNotWriteableRuntimeException(String message, String errorCode) {
+ super(message, errorCode);
+ }
+
+ public MessageNotWriteableRuntimeException(String message, String errorCode, Throwable cause) {
+ super(message, errorCode, cause);
+ }
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageProducer.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageProducer.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageProducer.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/MessageProducer.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,70 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface MessageProducer {
+ void setDisableMessageID(boolean value) throws JMSException;
+
+ boolean getDisableMessageID() throws JMSException;
+
+ void setDisableMessageTimestamp(boolean value) throws JMSException;
+
+ boolean getDisableMessageTimestamp() throws JMSException;
+
+ void setDeliveryMode(int deliveryMode) throws JMSException;
+
+ int getDeliveryMode() throws JMSException;
+
+ void setPriority(int defaultPriority) throws JMSException;
+
+ int getPriority() throws JMSException;
+
+ void setTimeToLive(long timeToLive) throws JMSException;
+
+ long getTimeToLive() throws JMSException;
+
+ Destination getDestination() throws JMSException;
+
+ void close() throws JMSException;
+
+ void send(Message message) throws JMSException;
+
+ void send(Message message, int deliveryMode, int priority, long timeToLive)
+ throws JMSException;
+
+ void send(Destination destination, Message message) throws JMSException;
+
+ void send(
+ Destination destination,
+ Message message,
+ int deliveryMode,
+ int priority,
+ long timeToLive)
+ throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ObjectMessage.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ObjectMessage.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ObjectMessage.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ObjectMessage.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,37 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+import java.io.Serializable;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface ObjectMessage extends Message {
+ void setObject(Serializable object) throws JMSException;
+
+ Serializable getObject() throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Queue.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Queue.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Queue.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Queue.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface Queue extends Destination {
+ String getQueueName() throws JMSException;
+
+ String toString();
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueBrowser.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueBrowser.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueBrowser.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueBrowser.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,41 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+import java.util.Enumeration;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface QueueBrowser extends AutoCloseable{
+ Queue getQueue() throws JMSException;
+
+ String getMessageSelector() throws JMSException;
+
+ Enumeration getEnumeration() throws JMSException;
+
+ void close() throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueConnection.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueConnection.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueConnection.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueConnection.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,41 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface QueueConnection extends Connection {
+ QueueSession createQueueSession(boolean transacted, int acknowledgeMode)
+ throws JMSException;
+
+ ConnectionConsumer createConnectionConsumer(
+ Queue queue,
+ String messageSelector,
+ ServerSessionPool sessionPool,
+ int maxMessages)
+ throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueConnectionFactory.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueConnectionFactory.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueConnectionFactory.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueConnectionFactory.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,36 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface QueueConnectionFactory extends ConnectionFactory {
+ QueueConnection createQueueConnection() throws JMSException;
+
+ QueueConnection createQueueConnection(String userName, String password)
+ throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueReceiver.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueReceiver.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueReceiver.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueReceiver.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,33 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface QueueReceiver extends MessageConsumer {
+ Queue getQueue() throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueRequestor.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueRequestor.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueRequestor.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueRequestor.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,94 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public class QueueRequestor {
+ private QueueSession session;
+ private TemporaryQueue temporaryQueue;
+ private QueueSender sender;
+ private QueueReceiver receiver;
+
+ public QueueRequestor(QueueSession session, Queue queue)
+ throws JMSException
+ {
+ super();
+
+ if(queue == null) {
+ throw new InvalidDestinationException("Invalid queue");
+ }
+
+ setSession(session);
+ setTemporaryQueue(session.createTemporaryQueue());
+ setSender(session.createSender(queue));
+ setReceiver(session.createReceiver(getTemporaryQueue()));
+ }
+
+ public Message request(Message message) throws JMSException {
+ message.setJMSReplyTo(getTemporaryQueue());
+ getSender().send(message);
+ return getReceiver().receive();
+ }
+
+ public void close() throws JMSException {
+ getSession().close();
+ getTemporaryQueue().delete();
+ }
+
+ private void setReceiver(QueueReceiver receiver) {
+ this.receiver = receiver;
+ }
+
+ private QueueReceiver getReceiver() {
+ return receiver;
+ }
+
+ private void setSender(QueueSender sender) {
+ this.sender = sender;
+ }
+
+ private QueueSender getSender() {
+ return sender;
+ }
+
+ private void setSession(QueueSession session) {
+ this.session = session;
+ }
+
+ private QueueSession getSession() {
+ return session;
+ }
+
+ private void setTemporaryQueue(TemporaryQueue temporaryQueue) {
+ this.temporaryQueue = temporaryQueue;
+ }
+
+ private TemporaryQueue getTemporaryQueue() {
+ return temporaryQueue;
+ }
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueSender.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueSender.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueSender.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueSender.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,48 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface QueueSender extends MessageProducer {
+ Queue getQueue() throws JMSException;
+
+ void send(Message message) throws JMSException;
+
+ void send(Message message, int deliveryMode, int priority, long timeToLive)
+ throws JMSException;
+
+ void send(Queue queue, Message message) throws JMSException;
+
+ void send(
+ Queue queue,
+ Message message,
+ int deliveryMode,
+ int priority,
+ long timeToLive)
+ throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueSession.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueSession.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueSession.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/QueueSession.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,47 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface QueueSession extends Session {
+ Queue createQueue(String queueName) throws JMSException;
+
+ QueueReceiver createReceiver(Queue queue) throws JMSException;
+
+ QueueReceiver createReceiver(Queue queue, String messageSelector)
+ throws JMSException;
+
+ QueueSender createSender(Queue queue) throws JMSException;
+
+ QueueBrowser createBrowser(Queue queue) throws JMSException;
+
+ QueueBrowser createBrowser(Queue queue, String messageSelector)
+ throws JMSException;
+
+ TemporaryQueue createTemporaryQueue() throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ResourceAllocationException.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ResourceAllocationException.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ResourceAllocationException.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ResourceAllocationException.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,40 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public class ResourceAllocationException extends JMSException {
+ public ResourceAllocationException(String reason, String errorCode) {
+ super(reason, errorCode);
+ }
+
+ public ResourceAllocationException(String reason) {
+ this(reason, null);
+ }
+
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ResourceAllocationRuntimeException.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ResourceAllocationRuntimeException.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ResourceAllocationRuntimeException.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ResourceAllocationRuntimeException.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,34 @@
+/*
+ * 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 javax.jms;
+
+public class ResourceAllocationRuntimeException extends JMSRuntimeException {
+ public ResourceAllocationRuntimeException(String message) {
+ super(message);
+ }
+
+ public ResourceAllocationRuntimeException(String message, String errorCode) {
+ super(message, errorCode);
+ }
+
+ public ResourceAllocationRuntimeException(String message, String errorCode, Throwable cause) {
+ super(message, errorCode, cause);
+ }
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ServerSession.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ServerSession.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ServerSession.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ServerSession.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface ServerSession {
+ Session getSession() throws JMSException;
+
+ void start() throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ServerSessionPool.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ServerSessionPool.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ServerSessionPool.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/ServerSessionPool.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,33 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface ServerSessionPool {
+ ServerSession getServerSession() throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Session.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Session.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Session.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Session.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,132 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+import java.io.Serializable;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface Session extends Runnable {
+ static final int AUTO_ACKNOWLEDGE = 1;
+
+ static final int CLIENT_ACKNOWLEDGE = 2;
+
+ static final int DUPS_OK_ACKNOWLEDGE = 3;
+
+ static final int SESSION_TRANSACTED = 0;
+
+ BytesMessage createBytesMessage() throws JMSException;
+
+ MapMessage createMapMessage() throws JMSException;
+
+ Message createMessage() throws JMSException;
+
+ ObjectMessage createObjectMessage() throws JMSException;
+
+ ObjectMessage createObjectMessage(Serializable object) throws JMSException;
+
+ StreamMessage createStreamMessage() throws JMSException;
+
+ TextMessage createTextMessage() throws JMSException;
+
+ TextMessage createTextMessage(String text) throws JMSException;
+
+ boolean getTransacted() throws JMSException;
+
+ int getAcknowledgeMode() throws JMSException;
+
+ void commit() throws JMSException;
+
+ void rollback() throws JMSException;
+
+ void close() throws JMSException;
+
+ void recover() throws JMSException;
+
+ MessageListener getMessageListener() throws JMSException;
+
+ void setMessageListener(MessageListener listener) throws JMSException;
+
+ public void run();
+
+ MessageProducer createProducer(Destination destination)
+ throws JMSException;
+
+ MessageConsumer createConsumer(Destination destination)
+ throws JMSException;
+
+ MessageConsumer createConsumer(
+ Destination destination,
+ String messageSelector)
+ throws JMSException;
+
+ MessageConsumer createConsumer(
+ Destination destination,
+ String messageSelector,
+ boolean NoLocal)
+ throws JMSException;
+
+ Queue createQueue(String queueName) throws JMSException;
+
+ Topic createTopic(String topicName) throws JMSException;
+
+ TopicSubscriber createDurableSubscriber(Topic topic, String name)
+ throws JMSException;
+
+ TopicSubscriber createDurableSubscriber(
+ Topic topic,
+ String name,
+ String messageSelector,
+ boolean noLocal)
+ throws JMSException;
+
+ QueueBrowser createBrowser(Queue queue) throws JMSException;
+
+ QueueBrowser createBrowser(Queue queue, String messageSelector)
+ throws JMSException;
+
+ TemporaryQueue createTemporaryQueue() throws JMSException;
+
+ TemporaryTopic createTemporaryTopic() throws JMSException;
+
+ void unsubscribe(String name) throws JMSException;
+
+ MessageConsumer createSharedConsumer(Topic topic, String sharedSubscriptionName) throws JMSException;
+
+ MessageConsumer createSharedConsumer(Topic topic, String sharedSubscriptionName, java.lang.String messageSelector)
+ throws JMSException;
+
+ MessageConsumer createDurableConsumer(Topic topic, String name) throws JMSException;
+
+ MessageConsumer createDurableConsumer(Topic topic, String name, String messageSelector, boolean noLocal) throws JMSException;
+
+ MessageConsumer createSharedDurableConsumer(Topic topic, String name) throws JMSException;
+
+ MessageConsumer createSharedDurableConsumer(Topic topic, String name, String messageSelector) throws JMSException;
+
+
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/StreamMessage.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/StreamMessage.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/StreamMessage.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/StreamMessage.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,79 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface StreamMessage extends Message {
+ boolean readBoolean() throws JMSException;
+
+ byte readByte() throws JMSException;
+
+ short readShort() throws JMSException;
+
+ char readChar() throws JMSException;
+
+ int readInt() throws JMSException;
+
+ long readLong() throws JMSException;
+
+ float readFloat() throws JMSException;
+
+ double readDouble() throws JMSException;
+
+ String readString() throws JMSException;
+
+ int readBytes(byte[] value) throws JMSException;
+
+ Object readObject() throws JMSException;
+
+ void writeBoolean(boolean value) throws JMSException;
+
+ void writeByte(byte value) throws JMSException;
+
+ void writeShort(short value) throws JMSException;
+
+ void writeChar(char value) throws JMSException;
+
+ void writeInt(int value) throws JMSException;
+
+ void writeLong(long value) throws JMSException;
+
+ void writeFloat(float value) throws JMSException;
+
+ void writeDouble(double value) throws JMSException;
+
+ void writeString(String value) throws JMSException;
+
+ void writeBytes(byte[] value) throws JMSException;
+
+ void writeBytes(byte[] value, int offset, int length) throws JMSException;
+
+ void writeObject(Object value) throws JMSException;
+
+ void reset() throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TemporaryQueue.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TemporaryQueue.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TemporaryQueue.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TemporaryQueue.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,33 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface TemporaryQueue extends Queue {
+ void delete() throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TemporaryTopic.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TemporaryTopic.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TemporaryTopic.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TemporaryTopic.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,33 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface TemporaryTopic extends Topic {
+ void delete() throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TextMessage.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TextMessage.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TextMessage.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TextMessage.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface TextMessage extends Message {
+ void setText(String string) throws JMSException;
+
+ String getText() throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Topic.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Topic.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Topic.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/Topic.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface Topic extends Destination {
+ String getTopicName() throws JMSException;
+
+ String toString();
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicConnection.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicConnection.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicConnection.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicConnection.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,49 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface TopicConnection extends Connection {
+ TopicSession createTopicSession(boolean transacted, int acknowledgeMode)
+ throws JMSException;
+
+ ConnectionConsumer createConnectionConsumer(
+ Topic topic,
+ String messageSelector,
+ ServerSessionPool sessionPool,
+ int maxMessages)
+ throws JMSException;
+
+ ConnectionConsumer createDurableConnectionConsumer(
+ Topic topic,
+ String subscriptionName,
+ String messageSelector,
+ ServerSessionPool sessionPool,
+ int maxMessages)
+ throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicConnectionFactory.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicConnectionFactory.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicConnectionFactory.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicConnectionFactory.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,36 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface TopicConnectionFactory extends ConnectionFactory {
+ TopicConnection createTopicConnection() throws JMSException;
+
+ TopicConnection createTopicConnection(String userName, String password)
+ throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicPublisher.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicPublisher.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicPublisher.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicPublisher.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,49 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+public interface TopicPublisher extends MessageProducer {
+ Topic getTopic() throws JMSException;
+
+ void publish(Message message) throws JMSException;
+
+ void publish(
+ Message message,
+ int deliveryMode,
+ int priority,
+ long timeToLive)
+ throws JMSException;
+
+ void publish(Topic topic, Message message) throws JMSException;
+
+ void publish(
+ Topic topic,
+ Message message,
+ int deliveryMode,
+ int priority,
+ long timeToLive)
+ throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicRequestor.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicRequestor.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicRequestor.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicRequestor.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,98 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public class TopicRequestor {
+ private TopicSession session;
+ private Topic topic;
+ private TemporaryTopic temporaryTopic;
+ private TopicPublisher publisher;
+ private TopicSubscriber subscriber;
+
+ public TopicRequestor(TopicSession session, Topic topic)
+ throws JMSException {
+ super();
+ setSession(session);
+ setTopic(topic);
+ setTemporaryTopic(session.createTemporaryTopic());
+ setPublisher(session.createPublisher(topic));
+ setSubscriber(session.createSubscriber(getTemporaryTopic()));
+ }
+
+ public Message request(Message message) throws JMSException {
+ message.setJMSReplyTo(getTemporaryTopic());
+ getPublisher().publish(message);
+ return (getSubscriber().receive());
+ }
+
+ public void close() throws JMSException {
+ getSession().close();
+ getTemporaryTopic().delete();
+ }
+
+ private void setPublisher(TopicPublisher publisher) {
+ this.publisher = publisher;
+ }
+
+ private TopicPublisher getPublisher() {
+ return publisher;
+ }
+
+ private void setSession(TopicSession session) {
+ this.session = session;
+ }
+
+ private TopicSession getSession() {
+ return session;
+ }
+
+ private void setSubscriber(TopicSubscriber subscriber) {
+ this.subscriber = subscriber;
+ }
+
+ private TopicSubscriber getSubscriber() {
+ return subscriber;
+ }
+
+ private void setTemporaryTopic(TemporaryTopic temporaryTopic) {
+ this.temporaryTopic = temporaryTopic;
+ }
+
+ private TemporaryTopic getTemporaryTopic() {
+ return temporaryTopic;
+ }
+
+ private void setTopic(Topic topic) {
+ this.topic = topic;
+ }
+
+ private Topic getTopic() {
+ return topic;
+ }
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicSession.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicSession.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicSession.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicSession.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,57 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface TopicSession extends Session {
+ Topic createTopic(String topicName) throws JMSException;
+
+ TopicSubscriber createSubscriber(Topic topic) throws JMSException;
+
+ TopicSubscriber createSubscriber(
+ Topic topic,
+ String messageSelector,
+ boolean noLocal)
+ throws JMSException;
+
+ TopicSubscriber createDurableSubscriber(Topic topic, String name)
+ throws JMSException;
+
+ TopicSubscriber createDurableSubscriber(
+ Topic topic,
+ String name,
+ String messageSelector,
+ boolean noLocal)
+ throws JMSException;
+
+ TopicPublisher createPublisher(Topic topic) throws JMSException;
+
+ TemporaryTopic createTemporaryTopic() throws JMSException;
+
+ void unsubscribe(String name) throws JMSException;
+}
Added: geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicSubscriber.java
URL: http://svn.apache.org/viewvc/geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicSubscriber.java?rev=1649017&view=auto
==============================================================================
--- geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicSubscriber.java (added)
+++ geronimo/specs/trunk/geronimo-jms_2.0_spec/src/main/java/javax/jms/TopicSubscriber.java Fri Jan 2 13:18:22 2015
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+//
+// This source code implements specifications defined by the Java
+// Community Process. In order to remain compliant with the specification
+// DO NOT add / change / or delete method signatures!
+//
+
+package javax.jms;
+
+/**
+ * @version $Rev: 467553 $ $Date: 2006-10-25 00:01:51 -0400 (Wed, 25 Oct 2006) $
+ */
+public interface TopicSubscriber extends MessageConsumer {
+ Topic getTopic() throws JMSException;
+
+ boolean getNoLocal() throws JMSException;
+}