Commitad87bd1

committed

Rename Discard singleton

1 parentacc2eb9 commitad87bd1Copy full SHA for ad87bd1

File tree

-3

lines changed

-3

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -17,5 +17,5 @@`
`17`	`17`	`* Simple marker for stopping publishing bytes`
`18`	`18`	`*/`
`19`	`19`	`publicenumDiscardEvent {`
`20`		`-INSTANCE`
	`20`	`+DISCARD`
`21`	`21`	`}`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,7 @@ public static void setAttribute(Channel channel, Object o) {`
`40`	`40`	`}`
`41`	`41`
`42`	`42`	`publicstaticvoidsetDiscard(Channelchannel) {`
`43`		`-setAttribute(channel,DiscardEvent.INSTANCE);`
	`43`	`+setAttribute(channel,DiscardEvent.DISCARD);`
`44`	`44`	`}`
`45`	`45`
`46`	`46`	`publicstaticbooleanisChannelValid(Channelchannel) {`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -102,7 +102,7 @@ public void channelRead(final ChannelHandlerContext ctx, Object msg) throws Exce`
`102`	`102`	`ctx.pipeline().remove(publisher);`
`103`	`103`	`Channels.setDiscard(channel);`
`104`	`104`	`}`
`105`		`- }elseif (attribute !=DiscardEvent.INSTANCE) {`
	`105`	`+ }elseif (attribute !=DiscardEvent.DISCARD) {`
`106`	`106`	`// unhandled message`
`107`	`107`	`logger.debug("Orphan channel {} with attribute {} received message {}, closing",channel,attribute,msg);`
`108`	`108`	`Channels.silentlyCloseChannel(channel);`

Comments

(0)