Skip to content

Conversation

@rjasmin-camsys
Copy link

No description provided.

… Service Impl. After getting that done, we begin testing.
…t. Still need to implement a "switching" methodology that will allow us to use either ZMQ or Kafka without code modifications. This should be about ready to test.
}

public void startListenerThread() {
if (_initialized == true) {
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please confirm if this is actually needed. Historically the DummyPartitionedInputQueueListener didn't actually implement any logic, and was simply a place holder.

public String getQueueName() {
return _configurationService.getConfigurationValueAsString(
"inference-engine.outputQueueName", null);
"inference-engine.outputQueueName", "bhs_queue");
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This isn't the right outputQueueName. We should probably avoid setting any defaults here to make it explicit that these need to be set.

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Is it possible to swap between ZMQ and Kafka without code changes?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants