diff --git a/examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/TelegramExamplesRunner.java b/examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/TelegramExamplesRunner.java index bc79b404795ca..e7d29f617ef55 100644 --- a/examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/TelegramExamplesRunner.java +++ b/examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/TelegramExamplesRunner.java @@ -18,9 +18,10 @@ import org.apache.camel.CamelContext; import org.apache.camel.StartupListener; -import org.apache.camel.example.telegram.usage.EditMessageLiveLocationUsage; import org.apache.camel.example.telegram.usage.GetUpdatesUsage; +import org.apache.camel.example.telegram.usage.LiveLocationUsage; import org.apache.camel.example.telegram.usage.SendMessageUsage; +import org.apache.camel.example.telegram.usage.SendVenueUsage; public class TelegramExamplesRunner implements StartupListener { @@ -30,8 +31,9 @@ public void onCamelContextStarted(CamelContext context, boolean alreadyStarted) // Methods usage examples new SendMessageUsage().run(context); - new EditMessageLiveLocationUsage().run(context); + new LiveLocationUsage().run(context); new GetUpdatesUsage().run(context); + new SendVenueUsage().run(context); } } diff --git a/examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/usage/EditMessageLiveLocationUsage.java b/examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/usage/LiveLocationUsage.java similarity index 76% rename from examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/usage/EditMessageLiveLocationUsage.java rename to examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/usage/LiveLocationUsage.java index d5d823eba4146..903680da82f2b 100644 --- a/examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/usage/EditMessageLiveLocationUsage.java +++ b/examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/usage/LiveLocationUsage.java @@ -21,8 +21,9 @@ import org.apache.camel.component.telegram.model.EditMessageLiveLocationMessage; import org.apache.camel.component.telegram.model.MessageResult; import org.apache.camel.component.telegram.model.SendLocationMessage; +import org.apache.camel.component.telegram.model.StopMessageLiveLocationMessage; -public class EditMessageLiveLocationUsage implements TelegramMethodUsage { +public class LiveLocationUsage implements TelegramMethodUsage { private double latitude = 59.9386292; private double longitude = 30.3141308; @@ -34,14 +35,21 @@ public void run(CamelContext context) throws InterruptedException { MessageResult firstLocationMessage = template.requestBody("direct:start", msg, MessageResult.class); System.out.println(firstLocationMessage); + long messageId = firstLocationMessage.getMessage().getMessageId(); + double delta = 0.001; - for (int i = 0; i < 5; i++) { + for (int i = 0; i < 3; i++) { double positionDelta = delta * (i + 1); EditMessageLiveLocationMessage liveLocationMessage = new EditMessageLiveLocationMessage(latitude + positionDelta, longitude + positionDelta); - liveLocationMessage.setMessageId(firstLocationMessage.getMessage().getMessageId()); + liveLocationMessage.setMessageId(messageId); MessageResult editedMessage = template.requestBody("direct:start", liveLocationMessage, MessageResult.class); System.out.println(editedMessage); Thread.sleep(3000); } + + StopMessageLiveLocationMessage stopLiveLocationMessage = new StopMessageLiveLocationMessage(); + stopLiveLocationMessage.setMessageId(messageId); + MessageResult stopMessage = template.requestBody("direct:start", stopLiveLocationMessage, MessageResult.class); + System.out.println(stopMessage); } } diff --git a/examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/usage/SendVenueUsage.java b/examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/usage/SendVenueUsage.java new file mode 100644 index 0000000000000..f667f6d053161 --- /dev/null +++ b/examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/usage/SendVenueUsage.java @@ -0,0 +1,38 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.camel.example.telegram.usage; + +import org.apache.camel.CamelContext; +import org.apache.camel.ProducerTemplate; +import org.apache.camel.component.telegram.model.EditMessageLiveLocationMessage; +import org.apache.camel.component.telegram.model.MessageResult; +import org.apache.camel.component.telegram.model.SendLocationMessage; +import org.apache.camel.component.telegram.model.SendVenueMessage; +import org.apache.camel.component.telegram.model.StopMessageLiveLocationMessage; + +public class SendVenueUsage implements TelegramMethodUsage { + + private double latitude = 59.9386292; + private double longitude = 30.3141308; + + public void run(CamelContext context) throws InterruptedException { + ProducerTemplate template = context.createProducerTemplate(); + SendVenueMessage msg = new SendVenueMessage(latitude, longitude, "MyTitle", "MyAddress"); + MessageResult result = template.requestBody("direct:start", msg, MessageResult.class); + System.out.println(result); + } +}