/** The connection. */
private Connection connection;
- /** The format. */
- private Format format;
-
@Inject
public MultiSourceFilter(EventBus eventBus) {
this.eventBus = eventBus;
@Override
public Format format() {
- return format;
+ synchronized (syncObject) {
+ return connection.source.format();
+ }
}
@Override
@Override
public void connect(Source source) throws ConnectException {
checkNotNull(source, "source must not be null");
- if (format != null) {
- checkArgument(format.equals(source.format()), "source’s format must equal this sink’s format");
- } else {
- format = source.format();
+ if ((connection != null) && (connection.source != null)) {
+ checkArgument(connection.source.format().equals(source.format()), "source’s format must equal this sink’s format");
}
if (connection == null) {