Как настроить OAuth2 security для Spring Cloud Stream?

Я разрабатываю микросервисное приложение. В качестве основного фреймворка использую Spring Cloud Data Flow, в качестве message broker'а -- RabbitMQ. Микросервисы коммуницируют между собой через брокера, REST-endpoint'ы имеются только на шлюзе для взаимодействия с клиентом, также шлюз является сервером аутентификации, выдающим oauth-токен. Настроить авторизацию я хочу локально на каждом микросервисе (подход global authentication, local authorization). Микросервисы обрабатывают поступающие на шину сообщения посредством методов, помеченных аннотацией @StreamListener. Моя проблема в том, что я не могу понять, как настроить для них security и, соответственно, как на эти методы навесить @PreAuthorize.