fix compiler error for release

Author: yuyijq

pom.xml

@@ -74,8 +74,8 @@
     </modules>
 
     <properties>
-        <java_source_version>1.7</java_source_version>
-        <java_target_version>1.7</java_target_version>
+        <java_source_version>1.8</java_source_version>
+        <java_target_version>1.8</java_target_version>
 
         <prometheus.client.version>0.5.0</prometheus.client.version>
         <spring.version>4.2.3.RELEASE</spring.version>

qmq-delay-server/src/main/java/qunar/tc/qmq/delay/receiver/Receiver.java

@@ -17,6 +17,7 @@
 package qunar.tc.qmq.delay.receiver;
 
 import com.google.common.base.CharMatcher;
+import com.google.common.base.Function;
 import com.google.common.eventbus.Subscribe;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
@@ -84,7 +85,7 @@ ListenableFuture<Datagram> receive(List<RawMessageExtend> messages, RemotingComm
 
         final short version = cmd.getHeader().getVersion();
         return Futures.transform(Futures.allAsList(futures)
-                , results -> RemotingBuilder.buildResponseDatagram(CommandCode.SUCCESS
+                , (Function<? super List<ReceivedResult>, ? extends Datagram>) results -> RemotingBuilder.buildResponseDatagram(CommandCode.SUCCESS
                         , cmd.getHeader(), new SendResultPayloadHolder(results, version)));
     }
 

qmq-server-common/pom.xml

@@ -23,6 +23,11 @@
             <groupId>${project.groupId}</groupId>
             <artifactId>qmq-remoting</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-annotations</artifactId>
+            <version>2.9.1</version>
+        </dependency>
         <dependency>
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-api</artifactId>

qmq-server/src/main/java/qunar/tc/qmq/processor/SendMessageWorker.java

@@ -17,6 +17,7 @@
 package qunar.tc.qmq.processor;
 
 import com.google.common.base.CharMatcher;
+import com.google.common.base.Function;
 import com.google.common.eventbus.Subscribe;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
@@ -76,7 +77,7 @@ ListenableFuture<Datagram> receive(final List<RawMessage> messages, final Remoti
 
         final short version = cmd.getHeader().getVersion();
         return Futures.transform(Futures.allAsList(futures),
-                input -> RemotingBuilder.buildResponseDatagram(CommandCode.SUCCESS, cmd.getHeader(), new SendResultPayloadHolder(input, version)));
+                (Function<? super List<ReceiveResult>, ? extends Datagram>) input -> RemotingBuilder.buildResponseDatagram(CommandCode.SUCCESS, cmd.getHeader(), new SendResultPayloadHolder(input, version)));
     }
 
     private void monitorMessageReceived(long receiveTime, String subject) {