[GitHub] [samza] mynameborat commented on a change in pull request #1015: SAMZA-2178: Utils to directly inject custom IME to InMemorySystem streams via TestRunner

[GitBox <gi...@apache.org>]

mynameborat commented on a change in pull request #1015: SAMZA-2178: Utils to directly inject custom IME to InMemorySystem streams via TestRunner
URL: https://github.com/apache/samza/pull/1015#discussion_r280854037
 
 

 ##########
 File path: samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemProducer.java
 ##########
 @@ -95,6 +96,15 @@ public void send(String source, OutgoingMessageEnvelope envelope) {
     memoryManager.put(ssp, key, message);
   }
 
+  /**
+   * Populates the IME to the ssp configured, this gives user more control to set up Test environment
+   *
+   * @param envelope
+   */
+  public void send(IncomingMessageEnvelope envelope) {
 
 Review comment:
   Thanks! Can you also add it is not thread safe?

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services