Package overit.geocallapp.wfm.core.ux.eventstreaming.client

Class ESClient

java.lang.Object

overit.geocallapp.wfm.core.ux.eventstreaming.client.ESClient

All Implemented Interfaces:

WebClientActions

Direct Known Subclasses:

DefaultRestClient, LocalStackRestClient

@Configuration
public abstract class ESClient
extends Object
implements WebClientActions

Constructor Summary

Constructors

Constructor	Description
ESClient()

Method Summary

Modifier and Type	Method	Description
org.springframework.web.client.RestClient	getEventStreamingRestClient()
protected abstract String	getServicesUrl()
void	purgeQueue(String endpoint)
String	readQueue(String endpoint)
String	subscribe(String arn, String endpoint)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ESClient

public ESClient()

Method Details

getEventStreamingRestClient

@Bean
public org.springframework.web.client.RestClient getEventStreamingRestClient()

getServicesUrl

protected abstract String getServicesUrl()

subscribe

public String subscribe(String arn,
 String endpoint)

Specified by:

subscribe in interface WebClientActions

readQueue

public String readQueue(String endpoint)

Specified by:

readQueue in interface WebClientActions

purgeQueue

public void purgeQueue(String endpoint)

Specified by:

purgeQueue in interface WebClientActions