Skip to content

Commit

Permalink
move stuff around more.
Browse files Browse the repository at this point in the history
  • Loading branch information
mariusae committed Jan 14, 2011
1 parent d68cccc commit a5505b3
Show file tree
Hide file tree
Showing 4 changed files with 10 additions and 2 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
// A test httpd that does ostrich logging & the works.



Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,11 @@ import org.jboss.netty.buffer.ChannelBuffer

import com.twitter.finagle.builder.Codec

class Thrift extends Codec[Array[Byte], Array[Byte]] {
object ThriftFramedTransportCodec {
def apply() = new ThriftFramedTransportCodec
}

class ThriftFramedTransportCodec extends Codec[Array[Byte], Array[Byte]] {
val clientPipelineFactory =
new ChannelPipelineFactory {
def getPipeline() = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ object FinagleClientThriftServerSpec extends Specification {
// ** Set up the client & query the server.
val service = ClientBuilder()
.hosts(Seq(thriftServerAddr))
.codec(new Thrift())
.codec(ThriftFramedTransportCodec())
.build()

val client = new Arithmetic.ServiceToClient(service, new TBinaryProtocol.Factory())
Expand Down

0 comments on commit a5505b3

Please sign in to comment.