Skip to content

Commit

Permalink
chore(docs): #13 renamed queue to task-queue to conform to Temporal u…
Browse files Browse the repository at this point in the history
…biquitous language
  • Loading branch information
snovak7 committed Apr 13, 2024
1 parent c981012 commit fe1202c
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 11 deletions.
14 changes: 7 additions & 7 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ This Keycloak SPI Event Listener integrates with Temporal Server, allowing you t

For instance, this is how an updated realm event triggered by an administrator might look:

- Queue: keycloak
- Task Queue: keycloak
- Namespace: default
- JSON:

Expand Down Expand Up @@ -55,18 +55,18 @@ Use the following command-line parameters:
|-----------------------------------------------------|
| --spi-events-listener-temporal-server=temporal:7233 |
| --spi-events-listener-temporal-namespace=default |
| --spi-events-listener-temporal-queue=keycloak |
| --spi-events-listener-temporal-task-queue=keycloak |


### Option 2: Environment Variables

Alternatively, you can set these environmental variables:

| Variable | Value |
|-------------------------------------------|---------------|
| KC_SPI_EVENTS_LISTENER_TEMPORAL_SERVER | temporal:7233 |
| KC_SPI_EVENTS_LISTENER_TEMPORAL_NAMESPACE | default |
| KC_SPI_EVENTS_LISTENER_TEMPORAL_QUEUE | keycloak |
| Variable | Value |
|--------------------------------------------|---------------|
| KC_SPI_EVENTS_LISTENER_TEMPORAL_SERVER | temporal:7233 |
| KC_SPI_EVENTS_LISTENER_TEMPORAL_NAMESPACE | default |
| KC_SPI_EVENTS_LISTENER_TEMPORAL_TASK_QUEUE | keycloak |

# License
This project is licensed under the Apache License 2.0 - see the [LICENSE](LICENSE) file for details.
Original file line number Diff line number Diff line change
Expand Up @@ -16,14 +16,14 @@ class TemporalEventListenerProviderFactory : EventListenerProviderFactory {
private var _workflowClient: WorkflowClient? = null
private var _server = ""
private var _namespace = ""
private var _queue = ""
private var _taskQueue = ""


override fun create(session: KeycloakSession?): EventListenerProvider {
if (_logger.isDebugEnabled) {
_logger.debugf("Creating %s", TemporalEventListenerProvider::class)
}
return TemporalEventListenerProvider(_workflowClient!!, _queue)
return TemporalEventListenerProvider(_workflowClient!!, _taskQueue)
}

override fun init(config: Config.Scope?) {
Expand All @@ -33,7 +33,7 @@ class TemporalEventListenerProviderFactory : EventListenerProviderFactory {

_server = config?.get("server") ?: "localhost:7233"
_namespace = config?.get("namespace") ?: "default"
_queue = config?.get("queue") ?: "keycloak"
_taskQueue = config?.get("task-queue") ?: "keycloak"

val workflowServiceStubsOptions = WorkflowServiceStubsOptions
.newBuilder()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ class TestScope : Scope {

private val _map: Map<String, String> = mapOf(
"server" to "localhost:7233",
"queue" to "default",
"task-queue" to "default",
"namespace" to "default"
)

Expand Down

0 comments on commit fe1202c

Please sign in to comment.