Author: jsdelfino
Date: Mon Sep 17 00:09:28 2007
New Revision: 576284
URL: http://svn.apache.org/viewvc?rev=576284&view=rev
Log:
Ported JMSBindingProviders to the updated Provider interface.
Modified:
incubator/tuscany/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingReferenceBindingProvider.java
incubator/tuscany/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java
Modified:
incubator/tuscany/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingReferenceBindingProvider.java
URL:
http://svn.apache.org/viewvc/incubator/tuscany/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingReferenceBindingProvider.java?rev=576284&r1=576283&r2=576284&view=diff
==============================================================================
---
incubator/tuscany/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingReferenceBindingProvider.java
(original)
+++
incubator/tuscany/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingReferenceBindingProvider.java
Mon Sep 17 00:09:28 2007
@@ -52,7 +52,7 @@
}
- public Invoker createInvoker(Operation operation, boolean isCallback) {
+ public Invoker createInvoker(Operation operation) {
if
(jmsBinding.getDestinationName().equals(JMSBindingConstants.DEFAULT_DESTINATION_NAME)){
throw new JMSBindingException("No destination specified for
reference " +
@@ -97,14 +97,14 @@
jmsBinding.setResponseDestinationName(reference.getName());
}
*/
- if (isCallback) {
- throw new UnsupportedOperationException();
- } else {
- JMSBindingInvoker invoker = new JMSBindingInvoker(jmsBinding,
- operation);
- jmsBindingInvokers.add(invoker);
- return invoker;
- }
+ JMSBindingInvoker invoker = new JMSBindingInvoker(jmsBinding,
+ operation);
+ jmsBindingInvokers.add(invoker);
+ return invoker;
+ }
+
+ public boolean supportsOneWayInvocation() {
+ return true;
}
public InterfaceContract getBindingInterfaceContract() {
Modified:
incubator/tuscany/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java
URL:
http://svn.apache.org/viewvc/incubator/tuscany/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java?rev=576284&r1=576283&r2=576284&view=diff
==============================================================================
---
incubator/tuscany/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java
(original)
+++
incubator/tuscany/java/sca/modules/binding-jms/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java
Mon Sep 17 00:09:28 2007
@@ -69,6 +69,10 @@
return service.getInterfaceContract();
}
+ public boolean supportsOneWayInvocation() {
+ return true;
+ }
+
public void start() {
try {
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
