Checkstyle and jdk11 fix with spock
This commit is contained in:
@@ -22,10 +22,12 @@ import com.fasterxml.jackson.annotation.JsonCreator;
|
||||
|
||||
@SuppressWarnings("serial")
|
||||
public class BookDeleted implements Serializable {
|
||||
|
||||
public final String bookName;
|
||||
|
||||
@JsonCreator(mode = JsonCreator.Mode.PROPERTIES)
|
||||
public BookDeleted(String bookName) {
|
||||
this.bookName = bookName;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -62,4 +62,5 @@ public class BookListener {
|
||||
}
|
||||
|
||||
public AtomicBoolean bookSuccessfulyDeleted = new AtomicBoolean(false);
|
||||
|
||||
}
|
||||
|
||||
@@ -22,10 +22,12 @@ import com.fasterxml.jackson.annotation.JsonCreator;
|
||||
|
||||
@SuppressWarnings("serial")
|
||||
public class BookReturned implements Serializable {
|
||||
|
||||
public final String bookName;
|
||||
|
||||
@JsonCreator(mode = JsonCreator.Mode.PROPERTIES)
|
||||
BookReturned(String bookName) {
|
||||
this.bookName = bookName;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -40,7 +40,7 @@ public class BookService {
|
||||
* a possibility to "trigger" sending of a message to the given messageFrom server
|
||||
* side: will run the method and await upon receiving message on the output
|
||||
* messageFrom
|
||||
*
|
||||
*
|
||||
* Method triggers sending a message to a source
|
||||
*/
|
||||
public void returnBook(BookReturned bookReturned) {
|
||||
@@ -48,4 +48,5 @@ public class BookService {
|
||||
this.source.output().send(MessageBuilder.withPayload(bookReturned)
|
||||
.setHeader("BOOK-NAME", bookReturned.bookName).build());
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -29,4 +29,5 @@ interface DeleteSink extends Sink {
|
||||
|
||||
@Input(DeleteSink.INPUT)
|
||||
SubscribableChannel delete();
|
||||
|
||||
}
|
||||
|
||||
@@ -23,10 +23,11 @@ import org.springframework.cloud.stream.messaging.Sink;
|
||||
import org.springframework.cloud.stream.messaging.Source;
|
||||
|
||||
@SpringBootApplication
|
||||
@EnableBinding({Source.class, Sink.class})
|
||||
@EnableBinding({ Source.class, Sink.class })
|
||||
class StreamMessagingApplication {
|
||||
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(StreamMessagingApplication.class, args);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user