Test und Counter fuer Rechnungsnummer

mc-b · Sep 9, 2018 · 0d54a20 · 0d54a20
1 parent f004e89
commit 0d54a20
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 5 deletions.
diff --git a/pom.xml b/pom.xml
@@ -104,7 +104,7 @@
 								</manifest>
 							</archive>
 						</configuration>
-					</execution>					
+					</execution>
 				</executions>
 			</plugin>
 		</plugins>
@@ -185,5 +185,10 @@
 			<artifactId>jersey-media-json-jackson</artifactId>
 			<version>2.27</version>
 		</dependency>
+		<dependency>
+			<groupId>org.glassfish.jersey.inject</groupId>
+			<artifactId>jersey-hk2</artifactId>
+			<version>2.27</version>
+		</dependency>
 	</dependencies>
 </project>
diff --git a/src/main/java/ch/mc_b/iot/kafka/AlertConsumer.java b/src/main/java/ch/mc_b/iot/kafka/AlertConsumer.java
@@ -31,6 +31,7 @@ public class AlertConsumer
 {
     private static final String REST_URI = "http://camunda:8080/engine-rest/process-definition/key/"; // <prozess>/start
     private static Client client = ClientBuilder.newClient();
+    private static int counter = 1;
 
     public static void main(String[] args) throws Exception
     {
@@ -54,17 +55,16 @@ public static void main(String[] args) throws Exception
                 String value = record.value();
                 if ( value != null && value.startsWith( "alert" ) )
                 {
-                    String text =  "{ \"variables\": { \"rnr\": {\"value\": " + 123 + ", \"type\": \"long\"}, " + 
+                    String text =  "{ \"variables\": { \"rnr\": {\"value\": " + counter++ + ", \"type\": \"long\"}, " + 
                                     "\"rbetrag\": {\"value\": " + 100.0 + ", \"type\": \"String\"} } }";
                     System.out.printf( "offset = %d, value = %s%n", offset, record.value() );
                     Response rc = client.target( REST_URI )
                                     .path( "RechnungStep3/start" )
-                                    .request(MediaType.TEXT_PLAIN)
-                                    .post(Entity.entity( text , MediaType.TEXT_PLAIN ) );
+                                    .request(MediaType.APPLICATION_JSON)
+                                    .post(Entity.entity( text , MediaType.APPLICATION_JSON ) );
                     System.out.println( rc.getStatus() );
                 }
             }
         }
     }
-
 }