RiakIORuntimeException

Dan Reverri dan at basho.com
Wed Jul 13 16:03:13 EDT 2011


Hi Maria,

The default port for the HTTP API is 8098; unless you changed app.config you
may just need to change the port specified in your code.

Thanks,
Dan

Daniel Reverri
Developer Advocate
Basho Technologies, Inc.
dan at basho.com


On Wed, Jul 13, 2011 at 10:43 AM, Russell Brown <russell.brown at me.com>wrote:

> Hi Maria,
> Is riak running? Can you verify it is running by using curl or wget?
>
>     curl -v -X GET http://localhost:8090/riak
>
> The errors says "connection refused" which tells me Riak is probably not
> running, or not running on the port you've specified (8090.)
>
> If you can get Riak running and verify that you have Riak running (maybe
> try the Fast Track [1] to get started) then try the Java client code again.
>
> Cheers
>
> Russell
>
> [1] Riak Fast Track - http://wiki.basho.com/The-Riak-Fast-Track.html
>
> On 13 Jul 2011, at 17:42, Maria Neise wrote:
>
> Hey,
> I am writing an application with the Java-Api. In my application I try
> to get a connection to Riak using the RiakClient in order to insert
> some data. Before, I downloaded Riak with wget
> http://downloads.basho.com/riak/riak-0.14/riak_0.14.2-1_amd64.deb.
> When I start Riak with
> sudo riak start I always get attempting to restart script through sudo
> -u riak. When I start my application I get an RiakIORuntimeException,
> when trying to store a RiakObject. Here is my code:
>
> public class RiakClient extends DB{
>
> com.basho.riak.client.http.RiakClient riakClient;
>
> public void init() throws DBException {
>
>  try{
>
>  riakClient = new
> com.basho.riak.client.http.RiakClient("http://localhost:8090/riak");
>
>
>  } catch(Throwable t) {
>  t.printStackTrace();
>  }
> }
>
> public int insert(String table, String key, HashMap<String, String> values)
> {
>
>  try{
>
>  com.basho.riak.client.http.RiakObject myObject = new
> com.basho.riak.client.http.RiakObject(table, key);
>
>  Iterator it = values.entrySet().iterator();
>  while(it.hasNext()){
>
>   Map.Entry<String,String> pair = (Map.Entry<String,String>)it.next();
>   String entryKey = pair.getKey();
>   String entryValue = pair.getValue();
>   myObject.addUsermetaItem(entryKey, entryValue);
>
>  }
>
>  com.basho.riak.client.http.response.StoreResponse storeResponse =
> riakClient.store(myObject);
>
>  if(!storeResponse.isSuccess()){
>   return 1;
>  }
>  } catch(Throwable t) {
>  t.printStackTrace();
>  }
>
>  return 0;
>
> }
>
> I also attached a screenshot from the Exception.
>
> I would be grateful for any advice.
> Cheers,
> Maria
> <connection_refused.jpg>_______________________________________________
> riak-users mailing list
> riak-users at lists.basho.com
> http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com
>
>
>
> _______________________________________________
> riak-users mailing list
> riak-users at lists.basho.com
> http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.basho.com/pipermail/riak-users_lists.basho.com/attachments/20110713/ce0738a0/attachment.html>


More information about the riak-users mailing list