This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new a47eaec CAMEL-11541: Improve example with stopMessageLiveLocation and
sendVenue methods usage (#2764)
a47eaec is described below
commit a47eaec412a1f669f79d886bc4570ecbee78cecf
Author: Denis Istomin <istomin....@gmail.com>
AuthorDate: Wed Feb 13 09:58:06 2019 +0500
CAMEL-11541: Improve example with stopMessageLiveLocation and sendVenue
methods usage (#2764)
---
.../example/telegram/TelegramExamplesRunner.java | 6 ++++--
...iveLocationUsage.java => LiveLocationUsage.java} | 14 +++++++++++---
...geLiveLocationUsage.java => SendVenueUsage.java} | 21 ++++++---------------
3 files changed, 21 insertions(+), 20 deletions(-)
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 bc79b40..e7d29f6 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 @@ package org.apache.camel.example.telegram;
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 class TelegramExamplesRunner implements
StartupListener {
// 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%
copy from
examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/usage/EditMessageLiveLocationUsage.java
copy to
examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/usage/LiveLocationUsage.java
index d5d823e..903680d 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.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.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 class EditMessageLiveLocationUsage implements
TelegramMethodUsage {
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/EditMessageLiveLocationUsage.java
b/examples/camel-example-telegram/src/main/java/org/apache/camel/example/telegram/usage/SendVenueUsage.java
similarity index 59%
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/SendVenueUsage.java
index d5d823e..f667f6d 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/SendVenueUsage.java
@@ -21,27 +21,18 @@ 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 EditMessageLiveLocationUsage implements TelegramMethodUsage {
+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();
- SendLocationMessage msg = new SendLocationMessage(latitude, longitude);
- msg.setLivePeriod(new Integer(60));
- MessageResult firstLocationMessage =
template.requestBody("direct:start", msg, MessageResult.class);
- System.out.println(firstLocationMessage);
-
- double delta = 0.001;
- for (int i = 0; i < 5; i++) {
- double positionDelta = delta * (i + 1);
- EditMessageLiveLocationMessage liveLocationMessage = new
EditMessageLiveLocationMessage(latitude + positionDelta, longitude +
positionDelta);
-
liveLocationMessage.setMessageId(firstLocationMessage.getMessage().getMessageId());
- MessageResult editedMessage = template.requestBody("direct:start",
liveLocationMessage, MessageResult.class);
- System.out.println(editedMessage);
- Thread.sleep(3000);
- }
+ SendVenueMessage msg = new SendVenueMessage(latitude, longitude,
"MyTitle", "MyAddress");
+ MessageResult result = template.requestBody("direct:start", msg,
MessageResult.class);
+ System.out.println(result);
}
}
