fix bindings

Activiti · Jan 27, 2023 · 85e426b · 85e426b
1 parent 5f237e8
commit 85e426b
Show file tree

Hide file tree

Showing 7 changed files with 14 additions and 14 deletions.
diff --git a/...tarter/src/main/java/org/activiti/cloud/examples/connectors/ExampleConnectorChannels.java b/...tarter/src/main/java/org/activiti/cloud/examples/connectors/ExampleConnectorChannels.java
@@ -15,14 +15,14 @@
  */
 package org.activiti.cloud.examples.connectors;
 
-import org.activiti.cloud.common.messaging.functional.OutputBinding;
+import org.activiti.cloud.common.messaging.functional.InputBinding;
 import org.springframework.integration.dsl.MessageChannels;
 import org.springframework.messaging.SubscribableChannel;
 
 public interface ExampleConnectorChannels {
     String EXAMPLE_CONNECTOR_CONSUMER = "exampleConnectorConsumer";
 
-    @OutputBinding(EXAMPLE_CONNECTOR_CONSUMER)
+    @InputBinding(EXAMPLE_CONNECTOR_CONSUMER)
     default SubscribableChannel exampleConnectorConsumer() {
         return MessageChannels.publishSubscribe(EXAMPLE_CONNECTOR_CONSUMER).get();
     }

diff --git a/...tarter/src/main/java/org/activiti/cloud/examples/connectors/HeadersConnectorChannels.java b/...tarter/src/main/java/org/activiti/cloud/examples/connectors/HeadersConnectorChannels.java
@@ -15,14 +15,14 @@
  */
 package org.activiti.cloud.examples.connectors;
 
-import org.activiti.cloud.common.messaging.functional.OutputBinding;
+import org.activiti.cloud.common.messaging.functional.InputBinding;
 import org.springframework.integration.dsl.MessageChannels;
 import org.springframework.messaging.SubscribableChannel;
 
 public interface HeadersConnectorChannels {
     String HEADERS_CONNECTOR_CONSUMER = "headersConnectorConsumer";
 
-    @OutputBinding(HEADERS_CONNECTOR_CONSUMER)
+    @InputBinding(HEADERS_CONNECTOR_CONSUMER)
     default SubscribableChannel headersConnectorConsumer() {
         return MessageChannels.publishSubscribe(HEADERS_CONNECTOR_CONSUMER).get();
     }

diff --git a/.../main/java/org/activiti/cloud/examples/connectors/MoviesDescriptionConnectorChannels.java b/.../main/java/org/activiti/cloud/examples/connectors/MoviesDescriptionConnectorChannels.java
@@ -15,14 +15,14 @@
  */
 package org.activiti.cloud.examples.connectors;
 
-import org.activiti.cloud.common.messaging.functional.OutputBinding;
+import org.activiti.cloud.common.messaging.functional.InputBinding;
 import org.springframework.integration.dsl.MessageChannels;
 import org.springframework.messaging.SubscribableChannel;
 
 public interface MoviesDescriptionConnectorChannels {
     String MOVIES_DESCRIPTION_CONSUMER = "moviesDescriptionConsumer";
 
-    @OutputBinding(MOVIES_DESCRIPTION_CONSUMER)
+    @InputBinding(MOVIES_DESCRIPTION_CONSUMER)
     default SubscribableChannel moviesDescriptionConsumer() {
         return MessageChannels.publishSubscribe(MOVIES_DESCRIPTION_CONSUMER).get();
     }

diff --git a/.../starter/src/main/java/org/activiti/cloud/examples/connectors/MultiInstanceConnector.java b/.../starter/src/main/java/org/activiti/cloud/examples/connectors/MultiInstanceConnector.java
@@ -23,7 +23,7 @@
 import org.activiti.cloud.api.process.model.IntegrationResult;
 import org.activiti.cloud.common.messaging.functional.Connector;
 import org.activiti.cloud.common.messaging.functional.ConnectorBinding;
-import org.activiti.cloud.common.messaging.functional.OutputBinding;
+import org.activiti.cloud.common.messaging.functional.InputBinding;
 import org.activiti.cloud.connectors.starter.channels.IntegrationResultSender;
 import org.activiti.cloud.connectors.starter.configuration.ConnectorProperties;
 import org.activiti.cloud.connectors.starter.model.IntegrationResultBuilder;
@@ -45,7 +45,7 @@ public class MultiInstanceConnector implements Connector<IntegrationRequest, Voi
     public interface Channels {
         String CHANNEL = "miCloudConnectorInput";
 
-        @OutputBinding(CHANNEL)
+        @InputBinding(CHANNEL)
         default SubscribableChannel miCloudConnectorInput() {
             return MessageChannels.publishSubscribe(CHANNEL).get();
         }

diff --git a/...connector/starter/src/main/java/org/activiti/cloud/examples/connectors/RestConnector.java b/...connector/starter/src/main/java/org/activiti/cloud/examples/connectors/RestConnector.java
@@ -21,7 +21,7 @@
 import org.activiti.cloud.api.process.model.IntegrationResult;
 import org.activiti.cloud.common.messaging.functional.Connector;
 import org.activiti.cloud.common.messaging.functional.ConnectorBinding;
-import org.activiti.cloud.common.messaging.functional.OutputBinding;
+import org.activiti.cloud.common.messaging.functional.InputBinding;
 import org.activiti.cloud.connectors.starter.channels.IntegrationResultSender;
 import org.activiti.cloud.connectors.starter.configuration.ConnectorProperties;
 import org.activiti.cloud.connectors.starter.model.IntegrationResultBuilder;
@@ -40,7 +40,7 @@ public class RestConnector implements Connector<IntegrationRequest, Void> {
     interface Channels {
         String POST = "restConnectorPost";
 
-        @OutputBinding(POST)
+        @InputBinding(POST)
         default SubscribableChannel restConnectorPost() {
             return MessageChannels.publishSubscribe(POST).get();
         }

diff --git a/.../starter/src/main/java/org/activiti/cloud/examples/connectors/TestBpmnErrorConnector.java b/.../starter/src/main/java/org/activiti/cloud/examples/connectors/TestBpmnErrorConnector.java
@@ -20,7 +20,7 @@
 import org.activiti.cloud.api.process.model.IntegrationRequest;
 import org.activiti.cloud.common.messaging.functional.Connector;
 import org.activiti.cloud.common.messaging.functional.ConnectorBinding;
-import org.activiti.cloud.common.messaging.functional.OutputBinding;
+import org.activiti.cloud.common.messaging.functional.InputBinding;
 import org.activiti.cloud.connectors.starter.channels.IntegrationErrorSender;
 import org.activiti.cloud.connectors.starter.configuration.ConnectorProperties;
 import org.activiti.cloud.connectors.starter.model.IntegrationErrorBuilder;
@@ -47,7 +47,7 @@ public TestBpmnErrorConnector(
     public interface Channels {
         String CHANNEL = "testBpmnErrorConnectorInput";
 
-        @OutputBinding(CHANNEL)
+        @InputBinding(CHANNEL)
         default SubscribableChannel testBpmnErrorConnectorInput() {
             return MessageChannels.publishSubscribe(CHANNEL).get();
         }

diff --git a/...ctor/starter/src/main/java/org/activiti/cloud/examples/connectors/TestErrorConnector.java b/...ctor/starter/src/main/java/org/activiti/cloud/examples/connectors/TestErrorConnector.java
@@ -21,7 +21,7 @@
 import org.activiti.cloud.api.process.model.IntegrationResult;
 import org.activiti.cloud.common.messaging.functional.Connector;
 import org.activiti.cloud.common.messaging.functional.ConnectorBinding;
-import org.activiti.cloud.common.messaging.functional.OutputBinding;
+import org.activiti.cloud.common.messaging.functional.InputBinding;
 import org.activiti.cloud.connectors.starter.channels.IntegrationResultSender;
 import org.activiti.cloud.connectors.starter.configuration.ConnectorProperties;
 import org.activiti.cloud.connectors.starter.model.IntegrationResultBuilder;
@@ -46,7 +46,7 @@ public class TestErrorConnector implements Connector<IntegrationRequest, Void> {
     public interface Channels {
         String CHANNEL = "testErrorConnectorInput";
 
-        @OutputBinding(CHANNEL)
+        @InputBinding(CHANNEL)
         default SubscribableChannel testErrorConnectorInput() {
             return MessageChannels.publishSubscribe(CHANNEL).get();
         }