Hi @msharpe > ,
That looks promising! Did you get it to work? I tried to copy your code to try it out but it wouldn’t compile for me. I tried fixing it but think I’m missing something small. If you got it working do you mind sharing? Either in the forum here or maybe just a link to a file on github?
FYI - if you use 3 tics in a row in the forum it will format your code to make it easier to read 
Example:
@Bean
public Consumer sink() {
return v → {
System.out.println(v);
};
}