public class ElasticsearchSituationStore extends AbstractSituationStore implements SituationStore
ASSIGNED_TO_PROPERTY, HOST_PROPERTY, RESOLUTION_STATE_PROPERTY, RESUBMIT_AT_PROPERTY, RESUBMIT_BY_PROPERTY, RESUBMIT_ERROR_MESSAGE, RESUBMIT_RESULT_ERROR, RESUBMIT_RESULT_PROPERTY, RESUBMIT_RESULT_SUCCESS
Constructor and Description |
---|
ElasticsearchSituationStore()
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
assignSituation(String situationId,
String userName)
This method assigns a situation to a specified user.
|
void |
close()
Close the situation store.
|
protected void |
doDelete(Situation situation)
This method deletes the supplied situation.
|
protected ElasticsearchClient |
getClient()
This method returns the elasticsearch client.
|
protected QueryBuilder |
getQueryBuilder(SituationsQuery sitQuery) |
protected int |
getResponseSize()
This method sets the response size.
|
Situation |
getSituation(String id)
This method returns the situation associated with the supplied id.
|
List<Situation> |
getSituations(SituationsQuery sitQuery)
This method returns the list of situations that meet the criteria
specified in the query.
|
void |
init()
Initialize the situation store.
|
protected boolean |
isNullOrEmpty(String str)
Check if the supplied string is null or empty (after removing
whitespaces).
|
void |
recordResubmitFailure(String situationId,
String errorMessage,
String userName)
Record's a failed resubmit of the situation matching the given id.
|
void |
recordSuccessfulResubmit(String situationId,
String userName)
Record's a successful resubmit of the situation matching the given id.
|
protected void |
setResponseSize(int size)
This method sets the response size.
|
void |
store(Situation situation)
This method persists the supplied situation.
|
void |
unassignSituation(String situationId)
This method unassigns a situation.
|
void |
updateResolutionState(String situationId,
ResolutionState resolutionState)
This method updates the resolution state of a situation.
|
delete, doAssignSituation, doDelete, doRecordResubmitFailure, doRecordSuccessfulResubmit, doUnassignSituation, doUpdateResolutionState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
delete
public void init()
protected void setResponseSize(int size)
size
- The sizeprotected int getResponseSize()
size
- The sizepublic void store(Situation situation) throws Exception
store
in interface SituationStore
situation
- The situationException
- Failed to store situationpublic Situation getSituation(String id)
getSituation
in interface SituationStore
id
- The idpublic List<Situation> getSituations(SituationsQuery sitQuery)
getSituations
in interface SituationStore
sitQuery
- The situations queryprotected QueryBuilder getQueryBuilder(SituationsQuery sitQuery)
protected boolean isNullOrEmpty(String str)
str
- The string to testpublic void assignSituation(String situationId, String userName)
assignSituation
in interface SituationStore
assignSituation
in class AbstractSituationStore
situationId
- The situation iduserName
- The userpublic void unassignSituation(String situationId)
unassignSituation
in interface SituationStore
unassignSituation
in class AbstractSituationStore
situationId
- The situation idpublic void updateResolutionState(String situationId, ResolutionState resolutionState)
updateResolutionState
in interface SituationStore
updateResolutionState
in class AbstractSituationStore
situationId
- The situation idresolutionState
- The resolution statepublic void recordSuccessfulResubmit(String situationId, String userName)
SituationStore
recordSuccessfulResubmit
in interface SituationStore
recordSuccessfulResubmit
in class AbstractSituationStore
situationId
- The situation iduserName
- The optional user id who resubmitted the message for this situationpublic void recordResubmitFailure(String situationId, String errorMessage, String userName)
SituationStore
recordResubmitFailure
in interface SituationStore
recordResubmitFailure
in class AbstractSituationStore
situationId
- The situation iderrorMessage
- The exception messageuserName
- The optional user id who resubmitted the message for this situationprotected void doDelete(Situation situation)
doDelete
in class AbstractSituationStore
situation
- The situationprotected ElasticsearchClient getClient()
public void close()
Copyright © 2013-2015 JBoss by Red Hat. All Rights Reserved.