zdm/envoy
Archived
3
Fork 0
Code Issues 22 Pull Requests Releases 1 Wiki Activity

Added message sending request

Browse Source
This commit is contained in:
Kai S. K. Engelbart
2019-09-28 16:23:00 +02:00
parent 9bae208d3f
commit 36910930bd
3 changed files with 39 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/main/java/envoy/EnvoyClient.java
View File

@@ -1,9 +1,18 @@
package envoy;
import java.time.Instant;
import javax.ws.rs.client.Client;
import javax.ws.rs.client.ClientBuilder;
import javax.ws.rs.client.Entity;
import javax.ws.rs.client.WebTarget;
import javax.ws.rs.core.Response;
import javax.xml.bind.JAXBException;
import javax.xml.datatype.DatatypeConfigurationException;
import javax.xml.datatype.DatatypeFactory;
import envoy.schema.Message;
import envoy.schema.ObjectFactory;
/**
* Project: <strong>envoy-client</strong><br>
@@ -13,13 +22,26 @@ import javax.ws.rs.core.Response;
*/
public class EnvoyClient {
public static void main(String[] args) {
Client client = ClientBuilder.newClient();
WebTarget target = client.target("http://localhost:8080/envoy-server/rest/hello?name=InformatikAGNGL");
Response response = target.request().get();
String value = response.readEntity(String.class);
response.close();
public static void main(String[] args) throws DatatypeConfigurationException, JAXBException {
ObjectFactory factory = new ObjectFactory();
System.out.printf("Response form server: %s%n", value);
Message.MetaData metaData = factory.createMessageMetaData();
metaData.setSender("Kai");
metaData.setRecipient("Maxi");
metaData.setState(false);
metaData.setDate(DatatypeFactory.newInstance().newXMLGregorianCalendar(Instant.now().toString()));
Message.Content content = factory.createMessageContent();
content.setType("text");
content.setText("Hello, World");
Message message = factory.createMessage();
message.setMetaData(metaData);
message.getContent().add(content);
Client client = ClientBuilder.newClient();
WebTarget target = client.target("http://localhost:8080/envoy-server/rest/message/send");
Response response = target.request().post(Entity.entity(message, "application/xml"));
response.close();
}
}